airflow.providers.grpc.hooks.grpc¶

GRPC Hook。

类¶

与 gRPC 服务器进行通用交互。

模块内容¶

class airflow.providers.grpc.hooks.grpc.GrpcHook(grpc_conn_id=default_conn_name, interceptors=None, custom_connection_func=None)[source]¶

基类: airflow.hooks.base.BaseHook

与 gRPC 服务器进行通用交互。

参数:

grpc_conn_id (str) – 获取连接信息时使用的连接 ID。
interceptors (list[Callable] | None) – 将应用于连接的 gRPC channel 的 gRPC 拦截器对象列表。默认为 None。每个拦截器应基于或继承四个官方 gRPC 拦截器，例如 UnaryUnaryClientInterceptor, UnaryStreamClientInterceptor, StreamUnaryClientInterceptor, StreamStreamClientInterceptor。
custom_connection_func (Callable | None) – 返回 gRPC channel 的自定义连接函数。一个可调用对象，接受连接作为其唯一参数。

conn_name_attr = 'grpc_conn_id'[source]¶

default_conn_name = 'grpc_default'[source]¶

conn_type = 'grpc'[source]¶

hook_name = 'GRPC Connection'[source]¶

classmethod get_connection_form_widgets()[source]¶

返回要添加到 GRPC 连接表单的连接组件。

grpc_conn_id = 'grpc_default'[source]¶

conn[source]¶

extras[source]¶

interceptors = [][source]¶

custom_connection_func = None[source]¶

get_conn()[source]¶

返回 hook 的连接。

run(stub_class, call_func, streaming=False, data=None)[source]¶

调用 gRPC 函数并将响应返回给调用者。

此条目有帮助吗？