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)-
Notifications
You must be signed in to change notification settings - Fork 0
Airflow x Aliyun RocketMQ
License
Ed-XCF/airflow-providers-aliyun-rocketmq
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
Airflow x Aliyun RocketMQ
Resources
License
Stars
Watchers
Forks
Packages 0
No packages published