AirbyteTriggerSyncOperator
AirbyteThis operator allows you to submit a job to an Airbyte server to run a integration process between your source and destination.
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_idRequired. The name of the Airflow connection to get connection information for Airbyte.
connection_idRequired. The Airbyte ConnectionId UUID between a source and destination.
asynchronousOptional. 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_versionOptional. Airbyte API version.
wait_secondsOptional. Number of seconds between checks. Only used when asynchronous is False.
timeoutOptional. 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