General interaction with gRPC servers.

View on GitHub

Last Updated: Nov. 3, 2022

Access Instructions

Install the gRPC provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


grpc_conn_idThe connection ID to use when fetching connection info.
interceptorsa list of gRPC interceptor objects which would be applied to the connected gRPC channel. None by default. Each interceptor should based on or extends the four official gRPC interceptors, eg, UnaryUnaryClientInterceptor, UnaryStreamClientInterceptor, StreamUnaryClientInterceptor, StreamStreamClientInterceptor.
custom_connection_funcThe customized connection function to return gRPC channel. A callable that accepts the connection as its only arg.


General interaction with gRPC servers.

Was this page helpful?