Saltar a contenido

bigquery_jobs

app.contrib.gcp.bigquery_jobs

Módulo de Python para manejar Jobs de Google Cloud BigQuery.

Para más información, te recomendamos leer la documentación del Proyecto:

BigQueryJobs

Genera una instancia con métodos sencillos para el manejo de Job en BigQuery.

Attributes:

Name Type Description
_bq_client Optional[Any]

donde almacenar la instancia de google.cloud.bigquery

Warning

esta clase:

  • se encuentra en revisión, puede cambiar en el futuro.
  • se necesitan más pruebas y ejemplos.

Raises:

Type Description
DefaultCredentialsError

en caso de que no se especifique credentials y la biblioteca no pueda adquirir las credenciales predeterminadas

DefaultException

excepciones para el manejo de errores personalizados

Examples:

1
2
3
4
from app.contrib.gcp.bigquery_jobs import BigQueryJobs

...
bq = BigQueryJobs()

__init__()

Constructor de la clase BigQueryJobs

get_list_jobs(max_results_jobs=10)

Obtiene una lista de los Jobs del proyecto en GCP.

Parameters:

Name Type Description Default
max_results_jobs int

el número de jobs a listar, por defecto, lista los 10 jobs más recientes en orden cronológico inverso

10

Returns:

Type Description
Optional[dict[str, list]]

un diccionario con información de los jobs, ó None en caso de error

Examples:

...
self.get_list_jobs()

get_job_info(job_id, location='us')

Obtiene la información de un Job.

Parameters:

Name Type Description Default
job_id str

el ID unico del Job

required
location str

la ubicación del dataset, por defecto "us".

'us'

Returns:

Type Description
Optional[dict[str, Any]]

un diccionario con información del job, ó None en caso de error

Examples:

...
self.get_job_info()

cancel_job(job_id, location='us')

Cancela un Job en progreso.

Parameters:

Name Type Description Default
job_id str

el ID unico del Job

required
location str

la ubicación del dataset, por defecto "us".

'us'

Returns:

Type Description
None

un diccionario con información del job, ó None en caso de error

Examples:

...
self.cancel_job()