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)