AirbyteTriggerSyncOperator

Airbyte

This operator allows you to submit a job to an Airbyte server to run a integration process between your source and destination.

View Source

Last Updated: May. 7, 2021

Access Instructions

Install the Airbyte provider package into your Airflow environment.

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

Parameters

airbyte_conn_idstrRequired. The name of the Airflow connection to get connection information for Airbyte.
connection_idstrRequired. The Airbyte ConnectionId UUID between a source and destination.
asynchronousboolOptional. Flag to get job_id after submitting the job to the Airbyte API. This is useful for submitting long running jobs and waiting on them asynchronously using the AirbyteJobSensor.
api_versionstrOptional. Airbyte API version.
wait_secondsfloatOptional. Number of seconds between checks. Only used when asynchronous is False.
timeoutfloatOptional. The amount of time, in seconds, to wait for the request to complete. Only used when asynchronous is False.

Documentation

This operator allows you to submit a job to an Airbyte server to run a integration process between your source and destination.

See also

For more information on how to use this operator, take a look at the guide: AirbyteTriggerSyncOperator

Was this page helpful?