معرفی شرکت ها

airflow-provider-rabbitmq-0.6.1

Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
Card image cap
تبلیغات ما

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

مشاهده بیشتر
0.6.1
0.6.0
0.6.1
0.6.0

توضیحات

A RabbitMQ provider for Apache Airflow
ویژگی مقدار
سیستم عامل -
نام فایل airflow-provider-rabbitmq-0.6.1
نام airflow-provider-rabbitmq
نسخه کتابخانه 0.6.1
نگهدارنده []
ایمیل نگهدارنده []
نویسنده Tes Engineering
ایمیل نویسنده engineering@tesglobal.com
آدرس صفحه اصلی -
آدرس اینترنتی https://pypi.org/project/airflow-provider-rabbitmq/
مجوز -
[![PyPI version](https://badge.fury.io/py/airflow-provider-rabbitmq.svg)](https://badge.fury.io/py/airflow-provider-rabbitmq) # RabbitMQ Provider for Apache Airflow ## Configuration In the Airflow user interface, configure a connection with the `Conn Type` set to RabbitMQ. Configure the following fields: - `Conn Id`: How you wish to reference this connection. The default value is `rabbitmq_default`. - `login`: Login for the RabbitMQ server. - `password`: Password for the RabbitMQ server., - `port`: Port for the RabbitMQ server, typically 5672. - `host`: Host of the RabbitMQ server. - `vhost`: The virtual host you wish to connect to. ## Modules ### RabbitMQ Operator The `RabbitMQOperator` publishes a message to your specificed RabbitMQ server. Import into your DAG using: ```Python from rabbitmq_provider.operators.rabbitmq import RabbitMQOperator ``` ### RabbitMQ Sensor The `RabbitMQSensor` checks a given queue for a message. Once it has found a message the sensor triggers downstream proccesses in your DAG. Import into your DAG using: ```Python from rabbitmq_provider.sensors.rabbitmq import RabbitMQSensor ``` ## Testing To run unit tests, use: ```shell poetry run pytest . ``` A RabbitMQ instance is required to run the tests. Use the following command: ```shell docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management ```


نیازمندی

مقدار نام
>=1.10 apache-airflow
>=1.2.0,<2.0.0 pika
>=0.3.2,<0.4.0 whippet


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

مقدار نام
>=3.7,<4.0 Python


نحوه نصب


نصب پکیج whl airflow-provider-rabbitmq-0.6.1:

    pip install airflow-provider-rabbitmq-0.6.1.whl


نصب پکیج tar.gz airflow-provider-rabbitmq-0.6.1:

    pip install airflow-provider-rabbitmq-0.6.1.tar.gz