How does python-socketio communicate with celery?

[zhenzi0322]

I was thinking of creating the task in python-socketio and then processing the task in celery to send the event, but the prompt says it's not at the same link

[miguelgrinberg]

I'm not sure what you mean. This package does not use or affect Celery in any way.

[zhenzi0322]

I'm not sure what you mean. This package does not use or affect Celery in any way.

Traceback (most recent call last):
  File "D:\packages\python\Envs\socketio-celery-rxAZY8Ac\lib\site-packages\celery\app\trace.py", line 451, in trace_task
    R = retval = fun(*args, **kwargs)
  File "D:\packages\python\Envs\socketio-celery-rxAZY8Ac\lib\site-packages\celery\app\trace.py", line 734, in __protected_call__
    return self.run(*args, **kwargs)
  File "E:\python-project\socketio-celery\tasks.py", line 33, in test_pick
    asyncio.run(main(data=data))
  File "D:\packages\python\python395\lib\asyncio\runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "D:\packages\python\python395\lib\asyncio\base_events.py", line 642, in run_until_complete
    return future.result()
  File "E:\python-project\socketio-celery\tasks.py", line 26, in main
    await service.start(data=data)
  File "E:\python-project\socketio-celery\service.py", line 17, in start
    await self.sio.emit("result", {"ddd": "start test"})
  File "D:\packages\python\Envs\socketio-celery-rxAZY8Ac\lib\site-packages\socketio\asyncio_client.py", line 213, in emit
    raise exceptions.BadNamespaceError(
socketio.exceptions.BadNamespaceError: / is not a connected namespace.

[miguelgrinberg]

Is this from a Celery worker process? Have you read the documentation with regards to emitting from an auxiliary process?

[zhenzi0322]

Is this from a Celery worker process? Have you read the documentation with regards to emitting from an auxiliary process?

Right, I was trying to send the completed task in celery via socketio

[miguelgrinberg]

I still don't understand what is the problem, or if you are asking me a question, what is the question. Can you clarify please? As I said, the documentation explains how to use this library from an auxiliary process. Your Celery worker is an auxiliary process, so you have to follow those instructions.