文件名称：trio-amqp:蛇人的异步消息传递
文件大小：74KB
文件格式：ZIP
更新时间：2024-06-19 09:39:48
Python
async_amqp async_amqp库是的纯 Python 实现。 它建立在，提供了基于协程的 API，可以轻松编写高并发应用程序。 欢迎报告错误、补丁和建议！ 只需打开一个或发送一个。 地位 该代码有效。 移植使用 aioamqp（甚至是普通的 python-amqp）的代码应该相当简单。 来自 aioamqp 的所有测试都已移植并成功。 async_amqp 是从 asyncamqp 重命名的，但这是在 pypi 上进行的。 asyncamqp 从 trio_amqp 重命名，但 anyio 支持被认为是一个好主意。 trio_amqp 又是从 aioamqp 分叉出来的。 测试 要运行测试，您需要安装 Python 测试依赖项： pip install -r ci/requirements_dev.txt 测试需要RabbitMQ的实例。 您可以使用 docker
【文件预览】：
trio-amqp-master
----MANIFEST.in(231B)
----.travis.yml(649B)
----README.rst(2KB)
----.readthedocs.yml(173B)
----.style.yapf(5KB)
----.coveragerc(116B)
----docs()
--------api.rst(11KB)
--------conf.py(8KB)
--------changelog.rst(4KB)
--------examples()
--------Makefile(7KB)
--------introduction.rst(434B)
--------index.rst(593B)
----AUTHORS.rst(632B)
----.pylintrc(2KB)
----pytest.ini(32B)
----CHANGES.rst(164B)
----Dockerfile(89B)
----tests()
--------test_consume.py(8KB)
--------test_properties.py(10KB)
--------test_connection_close.py(1KB)
--------conftest.py(68B)
--------testcase.py(12KB)
--------test_connection_lost.py(804B)
--------test_basic.py(8KB)
--------test_publish.py(3KB)
--------__init__.py(305B)
--------test_server_basic_cancel.py(549B)
--------test_close.py(2KB)
--------test_exchange.py(6KB)
--------test_connect.py(2KB)
--------test_protocol.py(3KB)
--------test_channel.py(3KB)
--------test_recover.py(621B)
--------test_queue.py(10KB)
--------test_heartbeat.py(924B)
----tox.ini(212B)
----docker-compose.yaml(318B)
----ci()
--------requirements_dev.txt(105B)
--------requirements.txt(0B)
----LICENSE(1KB)
----debian()
--------control(772B)
--------changelog(3KB)
--------compat(2B)
--------copyright(234B)
--------rules(170B)
--------.gitignore(83B)
--------source()
----release.conf(77B)
----setup.cfg(47B)
----examples()
--------new_task.py(746B)
--------send_with_return.py(1KB)
--------rpc_client.py(2KB)
--------emit_log.py(846B)
--------receive.py(707B)
--------receive_log.py(1KB)
--------emit_log_topic.py(905B)
--------receive_log_topic.py(1KB)
--------rpc_server.py(1KB)
--------receive_log_direct.py(1KB)
--------send.py(514B)
--------emit_log_direct.py(909B)
--------worker.py(783B)
----setup.py(1KB)
----.gitignore(631B)
----Makefile(2KB)
----async_amqp()
--------constants.py(2KB)
--------envelope.py(893B)
--------properties.py(2KB)
--------__init__.py(1KB)
--------channel.py(34KB)
--------frame.py(3KB)
--------future.py(1KB)
--------protocol.py(22KB)
--------exceptions.py(1KB)