معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Kafka integration for bluesky.

ویژگی	مقدار
سیستم عامل	-
نام فایل	bluesky-kafka-0.9.1
نام	bluesky-kafka
نسخه کتابخانه	0.9.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Brookhaven National Lab
ایمیل نویسنده	jlynch@bnl.gov
آدرس صفحه اصلی	https://github.com/bluesky/bluesky-kafka
آدرس اینترنتی	https://pypi.org/project/bluesky-kafka/
مجوز	BSD (3-clause)

=============================== bluesky-kafka =============================== .. image:: https://github.com/bluesky/bluesky-kafka/actions/workflows/tests.yml/badge.svg :target: https://github.com/bluesky/bluesky-kafka/actions .. image:: https://img.shields.io/pypi/v/bluesky-kafka.svg :target: https://pypi.python.org/pypi/bluesky-kafka Kafka integration for bluesky. * Free software: 3-clause BSD license Features -------- * BlueskyConsumer * MongoConsumer * Publisher * RemoteDispatcher Test ---- Install docker and docker-compose. Start a Kafka server: :: $ cd bluesky-kafka/scripts $ sudo docker-compose -f bitnami-kafka-docker-compose.yml up Run tests: :: $ cd bluesky-kafka $ pytest Optionally increase logging output to the console by specifying a logging level: :: $ pytest --log-cli-level=DEBUG Run a Mongo Consumer Group -------------------------- Create a conda environment: :: $ conda create -n consumers python=3.8 $ conda activate consumers Install packages: :: $ pip install bluesky-kafka supervisor Setup environment variables: mongo_uri reference: https://docs.mongodb.com/manual/reference/connection-string/ bootstrap_servers: comma-separated list of brokers. :: $ export BLUESKY_MONGO_URI="mongodb://username:password@machine1:port1,machine2:port2,machine3:port3 $ export KAFKA_BOOTSTRAP_SERVERS="machine1:9092, machine2:9092, machine3:9092" Update the bluesky_kafka/supervisor/supervisord.conf file with the correct path for your installation. Start the consumer processes: :: $ supervisord -c bluesky_kafka/supervisor/supervisord.conf Monitor the consumer processes: :: $ supervisorctl -c bluesky_kafka/supervisor/supervisorctl.conf

نیازمندی

مقدار	نام
-	bluesky
-	confluent-kafka
>=1.0.0	msgpack
-	msgpack-numpy
-	suitcase-mongo

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

مقدار	نام
>=3.6	Python

نحوه نصب

نصب پکیج whl bluesky-kafka-0.9.1:

pip install bluesky-kafka-0.9.1.whl

نصب پکیج tar.gz bluesky-kafka-0.9.1:

pip install bluesky-kafka-0.9.1.tar.gz