معرفی شرکت ها

asynckafka-0.2.0

Card image cap
تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر
Card image cap
تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر
Card image cap
تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر
Card image cap
تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر
Card image cap
تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر
0.2.0
0.1.3
0.1.2
0.1.1

توضیحات

Fast python kafka client for asyncio.
ویژگی مقدار
سیستم عامل -
نام فایل asynckafka-0.2.0
نام asynckafka
نسخه کتابخانه 0.2.0
نگهدارنده []
ایمیل نگهدارنده []
نویسنده José Melero Fernández
ایمیل نویسنده jmelerofernandez@gmail.com
آدرس صفحه اصلی http://github.com/jmf-mordis/asynckafka
آدرس اینترنتی https://pypi.org/project/asynckafka/
مجوز MIT
********** Asynckafka ********** .. image:: https://travis-ci.com/jmf-mordis/asynckafka.svg?branch=master :target: https://travis-ci.com/jmf-mordis/asynckafka Fast python Kafka client for asyncio. Asynckafka is written in Cython_ on top of Rdkafka_ as Kafka driver. .. _Cython: cython.org .. _Rdkafka: https://github.com/edenhill/librdkafka The documentation can be found here_. .. _here: https://jmf-mordis.github.io/asynckafka/ Features ======== * Consumer using a balanced group * Producer The library was born as a project to learn Cython, right now it only has the basic features implemented, some of the most important missing features are: * Offset management in the consumer * Precise partition management Examples ======== Simple consumer --------------- How to use a consumer:: consumer = Consumer( brokers='localhost:9092', topics=['my_topic'], group_id='my_group_id', ) consumer.start() async for message in consumer: print(f"Received message: {message.payload}") Simple producer --------------- How to use a producer:: producer = Producer(brokers="localhost:9092") producer.start() await producer.produce("my_topic", b"my_message") Benchmark ######### The test was performed in June of 2018 using a single Kafka broker without replication. The purpose of the benchmark was only to have an idea of the order of magnitude of the library's performance under these conditions. Comparison between asynckafka and aiokafka in production and consumption: Production ********** .. image:: https://github.com/jmf-mordis/asynckafka/raw/master/docs/benchmark/graphs/producer.png :width: 800 Consumption *********** .. image:: https://github.com/jmf-mordis/asynckafka/raw/master/docs/benchmark/graphs/consumer.png :width: 800 The benchmark used for asynckafka is in benchmark directory while the benchmark used for aiokafka is in its own repository, also in the benchmark folder.


نحوه نصب


نصب پکیج whl asynckafka-0.2.0:

    pip install asynckafka-0.2.0.whl


نصب پکیج tar.gz asynckafka-0.2.0:

    pip install asynckafka-0.2.0.tar.gz