A local client to work with Airbyte Cloud
Project description
shipyard-airbyte
Description
A local client to trigger Airbyte syncs and check statuses of past jobs
Installation
python3 -m pip install shipyard-airbyte
Usage
Establish the client by running the following
from shipyard_airbyte import AirbyteClient
ac = AirbyteClient(access_token = '<your_api_token>')
Trigger Syncs
To trigger a sync, you will need to provide the connector id to the trigger_sync
method, which will return the json response from the API
sync_response = ac.trigger_sync(connection_id = '<your_connection_id>')
print(sync_response)
Sync Status
To verify the status of a past sync, you will need the jobId
. This can be found from the sync_response shown above:
sync_response = ac.trigger_sync(connection_id = '<your_connection_id>')
job_id = sync_response['jobId']
sync_status = ac.get_sync_status(job_id)
print(sync_status)
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
shipyard_airbyte-0.1.6.tar.gz
(3.8 kB
view hashes)
Built Distribution
Close
Hashes for shipyard_airbyte-0.1.6-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 7cd4b3b6aa4d0b8af3e36ae1310bb51555f2997577a9c1faa60e3d463703079b |
|
MD5 | b54bc333bdf09d27e5acf6b87a115a7c |
|
BLAKE2b-256 | c309759919702639907f24a4ad25117e90839b63b79e21ba4fdaf7a7e0db13a2 |