kombu icon indicating copy to clipboard operation
kombu copied to clipboard

Celery does not support mongodb as a transport when url is in mongodb+srv:// format

Open mancioshell opened this issue 1 year ago • 0 comments

[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)

mancioshell avatar Sep 11 '23 15:09 mancioshell