`airflow.contrib.hooks.grpc_hook`¶

GRPC Hook

Module Contents¶

class airflow.contrib.hooks.grpc_hook.GrpcHook(grpc_conn_id, interceptors=None, custom_connection_func=None)[source]¶

Bases: airflow.hooks.base_hook.BaseHook

General interaction with gRPC servers.

get_conn(self)[source]¶

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

_get_field(self, field_name, default=None)[source]¶: Fetches a field from extras, and returns it. This is some Airflow magic. The grpc hook type adds custom UI elements to the hook page, which allow admins to specify scopes, credential pem files, etc. They get formatted as shown below.

Was this entry helpful?