airflow.providers.grpc.operators.grpc¶

类¶

GrpcOperator

调用 gRPC 端点来执行操作。

模块内容¶

class airflow.providers.grpc.operators.grpc.GrpcOperator(*, stub_class, call_func, grpc_conn_id='grpc_default', data=None, interceptors=None, custom_connection_func=None, streaming=False, response_callback=None, log_response=False, **kwargs)[source]¶

基类: airflow.models.BaseOperator

调用 gRPC 端点来执行操作。

参数:

stub_class (Callable) – 用于此 gRPC 调用的存根客户端
call_func (str) – 调用 gRPC 端点的客户端函数名
grpc_conn_id (str) – 此 Operator 将使用的连接 ID
data (dict | None) – 传递给 rpc 调用的数据
interceptors (list[Callable] | None) – 将在通道上使用的一系列 gRPC 拦截器对象
custom_connection_func (Callable | None) – 返回通道对象的自定义连接函数。它是一个可调用对象，接受连接作为其唯一的参数。
streaming (bool) – 指示调用是否为流式调用的标志
response_callback (Callable | None) – 用于处理 gRPC 调用响应的回调函数，接收响应对象和上下文对象，上下文对象可用于执行 push xcom 或其他任务后操作
log_response (bool) – 指示是否需要记录响应的标志

template_fields: collections.abc.Sequence[str] = ('stub_class', 'call_func', 'data')[source]¶

template_fields_renderers[source]¶

stub_class[source]¶

call_func[source]¶

grpc_conn_id = 'grpc_default'[source]¶

data[source]¶

interceptors = None[source]¶

custom_connection_func = None[source]¶

streaming = False[source]¶

log_response = False[source]¶

response_callback = None[source]¶

execute(context)[source]¶

创建 Operator 时派生此方法。

Context 是与渲染 jinja 模板时使用的相同的字典。

有关更多上下文，请参考 get_template_context。