معرفی شرکت ها

django-kafka-consumer-2.0.0

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

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

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

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

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

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

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

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

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

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

مشاهده بیشتر
2.0.0
2.0.0

توضیحات

-
ویژگی مقدار
سیستم عامل -
نام فایل django-kafka-consumer-2.0.0
نام django-kafka-consumer
نسخه کتابخانه 2.0.0
نگهدارنده []
ایمیل نگهدارنده []
نویسنده IIIT
ایمیل نویسنده github@iiit.pl
آدرس صفحه اصلی https://github.com/innovationinit/django-kafka-consumer
آدرس اینترنتی https://pypi.org/project/django-kafka-consumer/
مجوز BSD-2-Clause
Django Kafka Consumer ===================== Purpose ------- **Django Kafka Consumer** is an utility for consume events from [Kafka](https://kafka.apache.org/) Quick start ----------- 1. Add `kafka_consumer` to your `INSTALLED_APPS` setting like this: INSTALLED_APPS = [ # ... 'kafka_consumer', ] 2. Run `python manage.py migrate` to create the `kafka_consumer` models. 3. Add custom subscribers as classes derived from `kafka_consumer.subscribers.base.BaseSubscriber` 4. Prepare settings: KAFKA_HOSTS = ['kafka-host.com:9092'] KAFKA_CONSUMER_TOPICS = { 'topic_key': { 'topic': 'topic name', # no spaces allowed! 'group': 'topic group', 'client': 'client ID', 'subscribers': ( 'path.to.subscriber.Class', ), 'message_processor': 'processor key', # lookup in KAFKA_CONSUMERS_MESSAGE_PROCESSORS 'wait': 0, # optional, indicates how many seconds Kafka will wait to fillup buffer, None or ommited means wait forever 'max_number_of_messages_in_batch': 200, 'consumer_options': { # Overrides options used to create KafkaConsumer 'auto_offset_reset': 'latest', } }, } KAFKA_CONSUMERS_MESSAGE_PROCESSORS = { 'processor key': { 'class': 'path.to.messageprocessor.Class', # Processors init arguments, e.g. 'rsa_private_key_path': 'path/to/private/key' }, } KAFKA_CONSUMER_SSL_SETTINGS = { 'security_protocol': 'SSL', 'ssl_cafile': '/path/to/file/ca.crt', 'ssl_certfile': '/path/to/file/signed.request.crt', 'ssl_keyfile': '/path/to/some/keyfile.key', } 5. To continuously consume events from kafka run: python manage.py consume --supervised --topic topic_key License ------- The Django Kafka Consumer package is licensed under the [FreeBSD License](https://opensource.org/licenses/BSD-2-Clause).


نیازمندی

مقدار نام
==2.0.2 kafka-python
>=2.0,<3.0 Django
>=2021.3,<2022.0 pytz


زبان مورد نیاز

مقدار نام
>=3.7,<3.10 Python


نحوه نصب


نصب پکیج whl django-kafka-consumer-2.0.0:

    pip install django-kafka-consumer-2.0.0.whl


نصب پکیج tar.gz django-kafka-consumer-2.0.0:

    pip install django-kafka-consumer-2.0.0.tar.gz