kombu
kombu copied to clipboard
Celery does not support mongodb as a transport when url is in mongodb+srv:// format
[2023-09-11 17:50:28,633: CRITICAL/MainProcess] Unrecoverable error: InvalidURI('Bad database name "/myname:mypassword@myhost"') Traceback (most recent call last): File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\virtual\base.py", line 951, in create_channel return self._avail_channels.pop() IndexError: pop from empty list
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\worker.py", line 202, in start
self.blueprint.start(self)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\bootsteps.py", line 116, in start
step.start(parent)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\bootsteps.py", line 365, in start
return self.obj.start()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\consumer\consumer.py", line 340,
in start
blueprint.start(self)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\bootsteps.py", line 116, in start
step.start(parent)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\consumer\connection.py", line 21, in start
c.connection = c.connect()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\consumer\consumer.py", line 469,
in connect
conn = self.connection_for_read(heartbeat=self.amqheartbeat)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\consumer\consumer.py", line 475,
in connection_for_read
return self.ensure_connected(
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\celery\worker\consumer\consumer.py", line 526,
in ensure_connected
conn = conn.ensure_connection(
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\connection.py", line 406, in ensure_connection
self._ensure_connection(*args, **kwargs)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\connection.py", line 459, in _ensure_connection
return retry_over_time(
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\utils\functional.py", line 318, in retry_over_time
return fun(*args, **kwargs)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\connection.py", line 934, in _connection_factory
self._connection = self._establish_connection()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\connection.py", line 860, in _establish_connection
conn = self.transport.establish_connection()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\virtual\base.py", line 975, in
establish_connection
self._avail_channels.append(self.create_channel(self))
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\virtual\base.py", line 953, in
create_channel
channel = self.Channel(connection)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\mongodb.py", line 148, in init
self.client
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\utils\objects.py", line 31, in get
return super().get(instance, owner)
File "C:\Users\A409089.pyenv\pyenv-win\versions\3.8.1\lib\functools.py", line 966, in get
val = self.func(instance)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\mongodb.py", line 401, in client
return self._create_client()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\mongodb.py", line 393, in _create_client
database = self._open()
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\mongodb.py", line 337, in _open hostname, dbname, conf = self._parse_uri(scheme=scheme)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\kombu\transport\mongodb.py", line 307, in _parse_uri
parsed = uri_parser.parse_uri(hostname, port)
File "C:\git\ap31312\glin-plmmtrc-lan-mmtrc\src\workers.venv\lib\site-packages\pymongo\uri_parser.py", line 533, in parse_uri
raise InvalidURI('Bad database name "%s"' % dbase)