spumer

Why it should be based on aio-pika?

Hi, i'm develop and experiment with that now. Here my thread-safe transport implementation based on py-amqp: shared_pyamqp_transport.py ```python """ Do not share channel between threads: - Do not use `default_channel`...

This tested with 100 threads, but may have bugs, it's still experiment. Let me know if you will use it :)

So, i update snippet. Now it works correctly. Tested with 900 threads with huge consuming and producing. Each thread got message and enqueue same again and current message was acked.

@auvipy hi, what do you think about that? It's workaround implementation and may be you know the right way to implement this in py-amqp/kombu

https://pypi.org/project/kombu-pyamqp-threadsafe/

Fastapi 0.99 version released and it's support openapi 3.1.0 which add native support for `exampleS` https://fastapi.tiangolo.com/tutorial/schema-extra-example/#pydantic-and-fastapi-examples I was try it out, but no effect. Need more time investment @smagafurov

Sure

It was too hard to implement it in quick way. Need more refactoring @hongqn can you tell what is the "some circumstances" in your cases?

Do you have workaround for that case or you don't use fastapi-jsonrpc for this integration yet?