Untitled
unknown
plain_text
4 years ago
533 B
9
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...