基础知识
指南
参考资料
资源
系统测试
提交记录
RedisPublishOperator
向 Redis 发布消息。
基类: airflow.models.BaseOperator
airflow.models.BaseOperator
channel (str) – Redis 通道,消息将发布到该通道(模板化)
message (str) – 要发布的消息(模板化)
redis_conn_id (str) – 要使用的 Redis 连接
将消息发布到 Redis 通道。
context (airflow.sdk.definitions.context.Context) – 上下文对象
此条目有帮助吗?
RedisPublishOperator.template_fields
RedisPublishOperator.redis_conn_id
RedisPublishOperator.channel
RedisPublishOperator.message
RedisPublishOperator.execute()