You can use aio_pika with RPC pattern and do the following: Service 1 (consumes). Consume in a loop: # app/__init__.py from fastapi import ...
確定! 回上一頁