koji matsumoto
11/16/2021, 1:19 PMMichel
Michel
Jonas Bolin
11/17/2021, 1:25 PMJonas Bolin
11/17/2021, 1:25 PMkoji matsumoto
11/17/2021, 2:10 PMfrom google.cloud import storage
# export Airbyte config
req = urllib.request.Request(AIRBYTE_CONFIG_ENDPOINT, method='POST')
with urllib.request.urlopen(req) as data:
conf_data = data.read()
# upload Airbyte config to GCS
client = storage.Client()
bucket = client.get_bucket(BUCKET)
blob = bucket.blob(GCS_PATH)
blob.upload_from_string(conf_data, content_type='application/x-gzip')
Jonas Bolin
11/17/2021, 2:22 PMMax Krog
11/17/2021, 8:15 PMkoji matsumoto
11/18/2021, 12:16 AMkoji matsumoto
11/18/2021, 12:19 AM