文件名称：rejected:被拒绝的是RabbitMQ的消费者框架
文件大小：103KB
文件格式：ZIP
更新时间：2024-06-05 08:55:58
python framework rabbitmq amqp consumer
拒绝了 拒绝使用AMQP使用者守护程序和消息处理框架。 它通过处理与RabbitMQ进行通信和管理使用者进程的所有核心功能，可以快速开发消息处理使用者。 被拒绝的运行作为具有多个使用者配置的主流程运行，每个消费者配置都将其作为隔离的流程运行。 它具有从消费者流程中收集统计数据并对其进行报告的能力。 拒绝支持Python 2.7和3.4+。 特征 自动异常处理，包括连接管理和使用者重新启动 可以根据消息头自动对消息主体进行解码和反序列化的智能使用者类 指标记录并提交到statsd和InfluxDB 内置消费者代码分析 能够在使用者中编写异步代码，从而允许与外部资源进行并行通信 文献资料 消费者示例 from rejected import consumer import logging LOGGER = logging . getLogger ( __name__ ) class T
【文件预览】：
rejected-master
----MANIFEST.in(217B)
----README.rst(7KB)
----requires()
--------testing.txt(108B)
--------installation.txt(106B)
--------development.txt(39B)
----init.d()
--------rejected(911B)
----rejected()
--------process.py(34KB)
--------data.py(11KB)
--------mcp.py(24KB)
--------utils.py(2KB)
--------testing.py(17KB)
--------state.py(3KB)
--------log.py(4KB)
--------controller.py(5KB)
--------errors.py(4KB)
--------__init__.py(177B)
--------consumer.py(42KB)
--------smart_consumer.py(18KB)
--------connection.py(15KB)
--------mixins.py(2KB)
--------statsd.py(4KB)
----.codeclimate.yml(71B)
----examples()
--------examples.py(2KB)
--------setup.py(4KB)
--------README.md(10KB)
--------examples.yaml(4KB)
----.travis.yml(2KB)
----LICENSE(1KB)
----setup.cfg(248B)
----setup.py(2KB)
----docs()
--------consumers.rst(10KB)
--------api_internal.rst(464B)
--------testing.rst(1KB)
--------api_testing.rst(3KB)
--------conf.py(970B)
--------api_mixins.rst(208B)
--------installation.rst(647B)
--------api_consumers.rst(1KB)
--------history.rst(13KB)
--------example_config.rst(3KB)
--------configuration.rst(18KB)
--------api_data.rst(70B)
--------index.rst(2KB)
--------Makefile(7KB)
--------cli.rst(2KB)
--------api_exceptions.rst(817B)
--------api_consumer.rst(6KB)
--------api_smart_consumer.rst(8KB)
----tests()
--------test_mixins.py(1KB)
--------test_data.py(8KB)
--------test_consumer.py(21KB)
--------test_smart_consumer.py(16KB)
--------test_log.py(4KB)
--------test_errors.py(504B)
--------__init__.py(336B)
--------test_testing.py(826B)
--------test_mcp.py(822B)
--------test_state.py(8KB)
--------test_statsd.py(3KB)
--------test_process.py(9KB)
--------test_utils.py(2KB)
--------mocks.py(1KB)
--------test_percentile.py(650B)
--------common.py(1KB)
----.gitignore(114B)
----CHANGELOG.md(54B)