معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Asyncio kinesis client

ویژگی	مقدار
سیستم عامل	-
نام فایل	aiokinesis-0.0.4
نام	aiokinesis
نسخه کتابخانه	0.0.4
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Nik Liolios
ایمیل نویسنده	nik@asktetra.com
آدرس صفحه اصلی	-
آدرس اینترنتی	https://pypi.org/project/aiokinesis/
مجوز	-

AIOKinesis ========== Asyncio client library for AWS Kinesis Installation ------------ ``` pip install aiokinesis ``` AIOKinesisProducer ------------------ Usage: ```python import asycio from aiokinesis import AIOKinesisProducer async def send_message(): loop = asyncio.get_event_loop() producer = AIOKinesisProducer('my-stream-name', loop, region_name='us-east-1') await producer.start() await producer.send('partition-key', {'data': 'blah'}) await asyncio.sleep(1) await producer.stop() loop.run_until_complete(send_message()) ``` Limitations: - Stopping the producer before all messages are sent will prevent in flight messages from being sent - AIOKinesis only supports one shard so the producer is rate limited to 5 requests per rolling second AIOKinesisConsumer ------------------ Usage: ```python import asyncio from aiokinesis import AIOKinesisConsumer async def get_messages(): loop = asyncio.get_event_loop() consumer = AIOKinesisConsumer('my-stream-name', loop, region_name='us-east-1') await consumer.start() try: async for message in consumer: print("Consumed message: ", message) except KeyboardInterrupt: await consumer.stop() loop.run_until_complete() ``` Limitations: - AIOKinesis only supports one shard so the consumer is rate limited to 5 requests per rolling second

نیازمندی

مقدار	نام
==1.7.29	boto3

نحوه نصب

نصب پکیج whl aiokinesis-0.0.4:

pip install aiokinesis-0.0.4.whl

نصب پکیج tar.gz aiokinesis-0.0.4:

pip install aiokinesis-0.0.4.tar.gz