معرفی شرکت ها

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

تبلیغات ما

مشتریان به طور فزاینده ای آنلاین هستند. تبلیغات می تواند به آنها کمک کند تا کسب و کار شما را پیدا کنند.

مشاهده بیشتر

توضیحات

airflow grpc operator

ویژگی	مقدار
سیستم عامل	-
نام فایل	airflow-grpc-0.0.9
نام	airflow-grpc
نسخه کتابخانه	0.0.9
نگهدارنده	[]
ایمیل نگهدارنده	[]
نویسنده	Joseph Yin
ایمیل نویسنده	josephyin@outlook.com
آدرس صفحه اصلی	https://github.com/josephyin/airflow_grpc
آدرس اینترنتی	https://pypi.org/project/airflow-grpc/
مجوز	-

# Airflow Grpc Operator Fork on Airflow 2.0 Fix Airflow 1.10.x use grpc operator ## Requirements: ``` apache-airflow grpcio protobuf ``` ## How to install: ``` pip install airflow-grpc ``` ## How to use: * airflow 1.10.x ``` from airflow_grpc.grpc_operator import GrpcOperator args = { 'owner': 'Airflow', 'start_date': days_ago(1), } dag = DAG( dag_id='dag_id', default_args=args, schedule_interval=None ) def callback(response: Any, **context): return response run_this = GrpcOperator(task_id='task_id', dag=dag, grpc_conn_id='your_grpc_connection_id_on_admin_connections', stub_class=YOUR_GRPC_STUB_CLASS, call_func='your_grpc_stub_function', request_data_func=YOUR_GRPC_MESSAGE_FOR_REQUEST, response_callback=YOUR_RESPOSNE_METHOD, xcom_task_id='XCOM_TASK_ID', data=YOUR_REQUEST_DATA_DICT ) ``` * airflow 2.0.0 First must implement the stub_class method ``` import xxx_pb2_grpc, xxx_pb2 from utils.grpc_hook import BaseGrpcHook class xxxGrpcHook(BaseGrpcHook): def stub_class(self, channel): return xxx_pb2_grpc.xxxServiceStub(channel) ``` Use the implemented class ``` xxxGrpcHook().run('MethodName', {'request': xxx_pb2.xxxRequestMethod(**data_dict)}) ```

زبان مورد نیاز

مقدار	نام
>=3.6	Python

نحوه نصب

نصب پکیج whl airflow-grpc-0.0.9:

pip install airflow-grpc-0.0.9.whl

نصب پکیج tar.gz airflow-grpc-0.0.9:

pip install airflow-grpc-0.0.9.tar.gz