Untitled

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