Csvtogcs

flowtask.components.CSVToGCS

CSVToGCS

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

Bases: FlowComponent

CSVToGCS.

Este componente sube un archivo CSV desde el sistema local a un bucket específico de Google Cloud Storage (GCS). Opcionalmente, puede crear el bucket si no existe.

close async

close()

Cierra la conexión AsyncDB.

run async

run()

Ejecuta la carga del archivo CSV a GCS y retorna bucket_uri y object_uri.

start async

start(**kwargs)

Inicializa el componente configurando la conexión AsyncDB.