airflow.providers.redis.operators.redis_publish¶

類¶

RedisPublishOperator

向 Redis 釋出訊息。

模組內容¶

class airflow.providers.redis.operators.redis_publish.RedisPublishOperator(*, channel, message, redis_conn_id='redis_default', **kwargs)[source]¶

基類: airflow.models.BaseOperator

向 Redis 釋出訊息。

引數:

channel (str) – Redis 通道，訊息將釋出到該通道（模板化）
message (str) – 要釋出的訊息（模板化）
redis_conn_id (str) – 要使用的 Redis 連線

template_fields: collections.abc.Sequence[str] = ('channel', 'message')[source]¶

redis_conn_id = 'redis_default'[source]¶

channel[source]¶

message[source]¶

execute(context)[source]¶

將訊息釋出到 Redis 通道。

引數:: context (airflow.sdk.definitions.context.Context) – 上下文物件