معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Tarantool Queue python bindings for asyncio

ویژگی	مقدار
سیستم عامل	-
نام فایل	aiotarantool_queue-0.0.3
نام	aiotarantool_queue
نسخه کتابخانه	0.0.3
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Dmitry Shveenkov
ایمیل نویسنده	shveenkov@mail.ru
آدرس صفحه اصلی	https://github.com/shveenkov/aiotarantool-queue-python
آدرس اینترنتی	https://pypi.org/project/aiotarantool_queue/
مجوز	-

Tarantool Queue bindings for work with python asyncio ---------------------------------------------------------- Bindings require tarantool version 1.6 and aiotarantool connector: $ pip install aiotarantool_queue aiotarantool Try it example: .. code:: python import asyncio import aiotarantool_queue import random @asyncio.coroutine def put_job(queue): for tube_name in ("tube1", "tube2", "tube3"): tube = queue.tube(tube_name) task = yield from tube.put({"task_data": random.random()}) @asyncio.coroutine def take_job(tube): while True: task = yield from tube.take(5) if not task: break print(task.data) yield from task.ack() loop = asyncio.get_event_loop() queue = aiotarantool_queue.Queue("127.0.0.1", 3301) put_tasks = [asyncio.async(put_job(queue)) for _ in range(20)] take_tasks = [asyncio.async(take_job(queue.tube(tube_name))) for tube_name in ("tube1", "tube2", "tube3")] loop.run_until_complete(asyncio.wait(put_tasks + take_tasks)) loop.run_until_complete(queue.close()) loop.close() This code makes it easy to develop your application to work with queue.

نحوه نصب

نصب پکیج whl aiotarantool_queue-0.0.3:

pip install aiotarantool_queue-0.0.3.whl

نصب پکیج tar.gz aiotarantool_queue-0.0.3:

pip install aiotarantool_queue-0.0.3.tar.gz