Airflow x Aliyun RocketMQ
Project description
Airflow Provider for Aliyun RocketMQ
Example
from aliyun_rocketmq_provider.hooks.aliyun_rocketmq import AliyunRocketMQHook
message_push_topic = AliyunRocketMQHook(topic="message-push")
message_push_topic.run("helloWorld", fail_silently=True)
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for airflow-providers-aliyun-rocketmq-0.1.3.tar.gz
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | f86b7c1f8d59d30979bf105451260825b73cf101ac1dc6661aa7a1ecda1afe3d |
|
| MD5 | 536d05cf194806b2689ee2681b03bf0f |
|
| BLAKE2b-256 | 3d4670c48fb542fcc6e1cf12ee2a5844416e37c5d3d942c9da80db0ec1192f1d |
Close
Hashes for airflow_providers_aliyun_rocketmq-0.1.3-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | e285095f04cc1ec89be8a6d566d6024df53f5d8a266cc658cdc5450dc6cf18bc |
|
| MD5 | f33cd4fb25940e70b225f33334c5a643 |
|
| BLAKE2b-256 | 5358f71d758aa3f580290a88ebfd0c58ef4eec7385201bb863fecbc02858af9e |
