文件名称：guillotina_kafka:用于Guillotina应用程序的Kafka集成
文件大小：23KB
文件格式：ZIP
更新时间：2024-04-22 21:56:48
Python
guillotina_kafka文件 该软件包提供了一个guillotina插件，使您的guillotina应用程序支持kafka。 从本质上讲，它提供了两个API，一个用于生产Kafka，另一个用于从Kafka使用。 生产者 您可以按以下方式获取生产者实用程序： from guillotina_kafka . utilities import get_kafka_producer producer = get_kafka_producer () 然后根据您的要求设置生产者。 您可以在找到配置选项的详尽列表 await producer . setup ( request_timeout_ms = 5000 , value_serializer = lambda data : json . dumps ( data ). encode ( 'utf-8' ),
【文件预览】：
guillotina_kafka-master
----setup.py(1KB)
----.gitignore(490B)
----guillotina_kafka()
--------interfaces.py(577B)
--------utilities.py(3KB)
--------__init__.py(2KB)
--------producer()
--------install.py(522B)
--------events.py(219B)
--------api.py(1KB)
--------tests()
--------py.typed(0B)
--------subscribers.py(407B)
--------commands()
--------consumer()
----README.md(4KB)
----VERSION(5B)
----CHANGELOG.rst(2KB)
----config.json(2KB)