Untitled
Anonymous
plain_text
07/18/2021 12:46 PM
712 B
25
Indexable
load = GCSToBigQueryOperator(
task_id='load',
destination_project_dataset_table='ardhi-data-engineer.dataset.customers', #change to your bq
bucket=bucket_name,
source_objects=['customers.json'],
schema_object='customers_schema.json',
autodetect=False,
write_disposition='WRITE_TRUNCATE',
create_disposition='CREATE_IF_NEEDED',
source_format='NEWLINE_DELIMITED_JSON'
)Editor is loading...