معرفی شرکت ها

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

تبلیغات ما

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

مشاهده بیشتر

توضیحات

Bus for anyblok

ویژگی	مقدار
سیستم عامل	-
نام فایل	anyblok_bus-1.2.0
نام	anyblok_bus
نسخه کتابخانه	1.2.0
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	jssuzanne
ایمیل نویسنده	jssuzanne@anybox.fr
آدرس صفحه اصلی	http://docs.anyblok-bus.anyblok.org/1.2.0
آدرس اینترنتی	https://pypi.org/project/anyblok_bus/
مجوز	-

.. This file is a part of the AnyBlok / Bus project .. .. Copyright (C) 2018 Jean-Sebastien SUZANNE <jssuzanne@anybox.fr> .. .. This Source Code Form is subject to the terms of the Mozilla Public License, .. v. 2.0. If a copy of the MPL was not distributed with this file,You can .. obtain one at http://mozilla.org/MPL/2.0/. .. image:: https://img.shields.io/pypi/pyversions/anyblok_bus.svg?longCache=True :alt: Python versions .. image:: https://travis-ci.org/AnyBlok/anyblok_bus.svg?branch=master :target: https://travis-ci.org/AnyBlok/anyblok_bus :alt: Build status .. image:: https://coveralls.io/repos/github/AnyBlok/anyblok_bus/badge.svg?branch=master :target: https://coveralls.io/github/AnyBlok/anyblok_bus?branch=master :alt: Coverage .. image:: https://img.shields.io/pypi/v/anyblok_bus.svg :target: https://pypi.python.org/pypi/anyblok_bus/ :alt: Version status .. image:: https://readthedocs.org/projects/anyblok-bus/badge/?version=latest :alt: Documentation Status :scale: 100% :target: https://doc.anyblok-bus.anyblok.org/?badge=latest AnyBlok / bus ============= Improve `AnyBlok <http://doc.anyblok.org>`_ to add comunication with bus. +---------+--------------+------------------------------------------------------------------+ | Blok | Dependancies | Description | +=========+==============+==================================================================+ | **bus** | | Consume and publish message with | | | | `pika <https://pika.readthedocs.io>`_ and | | | | `marshmallow <https://github.com/marshmallow-code/marshmallow>`_ | +---------+--------------+------------------------------------------------------------------+ AnyBlok / Bus is released under the terms of the `Mozilla Public License`. See the `latest documentation <http://doc.anyblok-bus.anyblok.org/>`_ .. This file is a part of the AnyBlok / Bus project .. .. Copyright (C) 2018 Jean-Sebastien SUZANNE <jssuzanne@anybox.fr> .. .. This Source Code Form is subject to the terms of the Mozilla Public License, .. v. 2.0. If a copy of the MPL was not distributed with this file,You can .. obtain one at http://mozilla.org/MPL/2.0/. .. contents:: Usage ===== Declare a new consumer ---------------------- In an AnyBlok Model you have to decorate a method with **bus_consumer** :: from anyblok_bus import bus_consumer from anyblok import Declarations from .schema import MySchema @Declarations.register(Declarations.Model) class MyModel: @bus_consumer(queue_name='name of the queue', schema=MySchema()) def my_consumer(cls, body): # do something The schema must be an instance of marshmallow.Schema, `see the marshmallow documentation <http://marshmallow.readthedocs.io/en/latest/>`_ .. note:: The decorated method become a classmethod with always the same prototype (cls, body) body is the desarialization of the message from the queue by the schema. Publish a message through rabbitmq ---------------------------------- The publication is done by **registry.Bus.publish** method:: registry.Bus.publish('exchange', 'routing_key', message, mimestype) if the message have not be send, then an exception is raised ..warning:: A profile must be defined and selected by the AnyBlok configuration **bus_profile** .. This file is a part of the AnyBlok / Bus project .. .. Copyright (C) 2017 Jean-Sebastien SUZANNE <jssuzanne@anybox.fr> .. Copyright (C) 2018 Jean-Sebastien SUZANNE <jssuzanne@anybox.fr> .. Copyright (C) 2019 Jean-Sebastien SUZANNE <js.suzanne@gmail.com> .. .. This Source Code Form is subject to the terms of the Mozilla Public License, .. v. 2.0. If a copy of the MPL was not distributed with this file,You can .. obtain one at http://mozilla.org/MPL/2.0/. Front Matter ============ Information about the AnyBlok / Bus project. Project Homepage ---------------- AnyBlok is hosted on `github <http://github.com>`_ - the main project page is at https://github.com/AnyBlok/anyblok_bus. Source code is tracked here using `GIT <https://git-scm.com>`_. Releases and project status are available on Pypi at http://pypi.python.org/pypi/anyblok_bus. The most recent published version of this documentation should be at http://doc.anyblok-bus.anyblok.org. Installation ------------ Install released versions of AnyBlok from the Python package index with `pip <http://pypi.python.org/pypi/pip>`_ or a similar tool:: pip install anyblok_bus Installation via source distribution is via the ``setup.py`` script:: python setup.py install Installation will add the ``anyblok`` commands to the environment. Unit Test --------- Run the test with ``nose``:: pip install nose nosetests anyblok_bus/tests Script ------ anyblok_bus add ``console_script`` to launch worker. A worker consume a queue defined by the decorator **anyblok_bus.bus_consumer**:: anyblok_bus -c anyblok_config_file.cfg ..note:: The profile name in the configuration is used to find the correct url to connect to rabbitmq Dependencies ------------ AnyBlok / Bus works with **Python >= 3.4** and later and `pika >= 1.0.1 <https://pika.readthedocs.io>`_. The install process will ensure that `AnyBlok <http://doc.anyblok.org>`_ is installed, in addition to other dependencies. The latest version of them is strongly recommended. Author ------ Jean-Sébastien Suzanne Contributors ------------ `Anybox <http://anybox.fr>`_ team: * Jean-Sébastien Suzanne * Florent Jouatte `Sensee <http://sensee.com>`_ team: * Julien SZKUDLAPSKI * Jean-Sébastien Suzanne Bugs ---- Bugs and feature enhancements to AnyBlok should be reported on the `Issue tracker <https://github.com/AnyBlok/anyblok_bus/issues>`_. .. This file is a part of the AnyBlok / Bus project .. .. Copyright (C) 2018 Jean-Sebastien SUZANNE <jssuzanne@anybox.fr> .. Copyright (C) 2019 Jean-Sebastien SUZANNE <js.suzanne@gmail.com.fr> .. .. This Source Code Form is subject to the terms of the Mozilla Public License, .. v. 2.0. If a copy of the MPL was not distributed with this file,You can .. obtain one at http://mozilla.org/MPL/2.0/. .. contents:: CHANGELOG ========= 1.2.0 (2019-06-24) ------------------ * Update version to use pika >= 1.0.1 * Fixed Multiple consumer on the same model * Refactored bus console script, Added processes parameter on bus_consumer. The goal is to define processes for one queue, by default all the queues are in the same process * Add better logging when a queue is missing. If a queue is missing, then workers won't start. * Added adapter parameter to transform bus message, the schema attribute become now a simple kwargs argument give to adapter. The adapter is not required. .. note:: To keep the compatibility, if no adapter is defined with a schema then the adapter is schema_adapter 1.1.0 (2018-09-15) ------------------ * Improved logging: for helping to debug the messages * Added create and update date columns * fixed ``consume_all`` method. now the method does not stop when an exception is raised * Used marsmallow version >= 3.0.0 1.0.0 (2018-06-05) ------------------ * add Worker to consume the message from rabbitmq * add publish method to publish a message to rabbitmq * add **anyblok_bus.bus_consumer** add decorator to défine the consumer

نحوه نصب

نصب پکیج whl anyblok_bus-1.2.0:

pip install anyblok_bus-1.2.0.whl

نصب پکیج tar.gz anyblok_bus-1.2.0:

pip install anyblok_bus-1.2.0.tar.gz