معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Brokkoly is a framework for enqueuing messages via HTTP request for celery.

ویژگی	مقدار
سیستم عامل	-
نام فایل	brokkoly-0.3.1
نام	brokkoly
نسخه کتابخانه	0.3.1
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Motoki Naruse
ایمیل نویسنده	motoki@naru.se
آدرس صفحه اصلی	https://github.com/narusemotoki/brokkoly
آدرس اینترنتی	https://pypi.org/project/brokkoly/
مجوز	MIT

======== Brokkoly ======== .. image:: https://travis-ci.org/narusemotoki/brokkoly.svg?branch=master :target: https://travis-ci.org/narusemotoki/brokkoly Brokkoly is a framework for enqueuing messages via HTTP request for celery. `CHANGELOG <https://github.com/narusemotoki/brokkoly/blob/master/CHANGELOG.rst>`_ Example ======= tasks.py: --------- .. code-block:: python import brokkoly b = brokkoly.Brokkoly('example', 'redis://localhost:6379/0') celery = b.celery def two_times(text: str) -> dict: return { 'text': text * 2 } @b.task(two_times) def echo(text: str) -> None: print(text) :code:`two_times` works as pre processor. It works before enqueing. It means it can return BadRequest to your client. Brokkoly validate message with typehint. Also you can have extra validation and any other process here. Run :code:`celery -A tasks worker --loglevel=info` producer.py: ------------ .. code-block:: python import brokkoly import tasks # NOQA application = brokkoly.producer() `producer` is WSGI application. You need to import your `tasks` for put message into queue. Run with uWSGI :code:`uwsgi --http :8080 --wsgi-file producer.py --enable-threads --thunder-lock --master` Send Test Message! ------------------ :code:`curl -X POST -d '{"message":{"text": "Hello"}}' http://localhost:8080/example/echo` 1. `producer` receives your request 2. `producer` validates your message having `text` and the type is `str` or not. `text`(str)` is from typehint of :code:`two_times` 3. `producer` validates `two_times` returned value having `text` and the type is `str` or not. `text`(str)` is from typehint of :code:`echo` 4. `producer` put message :code:`{"message":{"text":"HelloHello"}}` into queue. 5. `curl` receives response. 6. `Celery` calls :code:`echo` Extra ===== preprocessor is optional. if you don't need it, you can: .. code-block:: python @b.task() def echo(text: str) -> None: print(text) Also you can give multiple preprocessor: .. code-block:: python @b.task(two_times, two_times) def echo(text: str) -> None: print(text)

نحوه نصب

نصب پکیج whl brokkoly-0.3.1:

pip install brokkoly-0.3.1.whl

نصب پکیج tar.gz brokkoly-0.3.1:

pip install brokkoly-0.3.1.tar.gz