Gcstobigquery

flowtask.components.GCSToBigQuery

GCSToBigQuery

GCSToBigQuery(loop=None, job=None, stat=None, **kwargs)

Bases: FlowComponent

GCSToBigQuery.

Este componente carga un archivo CSV desde un bucket específico de GCS a una tabla de BigQuery.

close async

close()

Cierra la conexión AsyncDB.

run async

run()

Ejecuta la carga del CSV desde GCS a BigQuery.

start async

start(**kwargs)

Inicializa el componente configurando la conexión AsyncDB.