文件名称：kq:基于Kafka的Python作业队列
文件大小：29KB
文件格式：ZIP
更新时间：2024-05-23 19:31:39
python kafka python3 queueing kafka-consumer
KQ：适用于Python的Kafka作业队列 KQ（Kafka队列）是一个轻量级的Python库，可让您使用异步入队和执行作业。 它在使用 。 公告内容 KQ版本3.0.0将不再支持Python 3.5。 请参阅以获取最新更新。 要求 0.9+ Python 3.6+ 安装 使用安装： pip install kq 入门 启动您的Kafka实例。 使用Docker的示例： docker run -p 9092:9092 -e ADV_HOST=127.0.0.1 lensesio/fast-data-dev 定义您的KQ worker.py模块： import logging from kafka import KafkaConsumer from kq import Worker # Set up logging. formatter = logging . Forma
【文件预览】：
kq-main
----MANIFEST.in(38B)
----example()
--------queue.py(304B)
--------producer.py(183B)
--------consumer.py(137B)
--------worker.py(3KB)
----pyproject.toml(252B)
----docs()
--------serializer.rst(1KB)
--------conf.py(302B)
--------callback.rst(2KB)
--------make.bat(760B)
--------job.rst(1KB)
--------logging.rst(1KB)
--------queue.rst(85B)
--------overview.rst(2KB)
--------Makefile(634B)
--------index.rst(934B)
--------message.rst(657B)
--------worker.rst(89B)
----.github()
--------workflows()
----tests()
--------test_worker.py(5KB)
--------test_utils.py(3KB)
--------conftest.py(5KB)
--------__init__.py(0B)
--------test_queue.py(7KB)
----LICENSE(1KB)
----kq()
--------queue.py(12KB)
--------job.py(1006B)
--------message.py(337B)
--------utils.py(2KB)
--------__init__.py(200B)
--------worker.py(9KB)
----CONTRIBUTING.md(647B)
----setup.cfg(211B)
----setup.py(1KB)
----.gitignore(1KB)
----README.md(3KB)
----.pre-commit-config.yaml(773B)