hexpop.py
def bq_query_table(query, destination=None, write='WRITE_APPEND'):
    """Query BigQuery table using SQL."""
    client = bq_client()
    job_config = bigquery.QueryJobConfig(
        destination=destination,
        write_disposition=write  # default append existing
    )
    job = client.query(query=query, job_config=job_config)
    try:
        result = job.result()  # wait for job to complete
    except NotFound:
        return None
    return result
Query BigQuery table using SQL.
Query BigQuery table using SQL.
Query BigQuery table using SQL .
def bq_query_table(query, destination=None, write='WRITE_APPEND'):
    client = bq_client()
    job_config = bigquery.QueryJobConfig(
        destination=destination,
        write_disposition=write  
    )
    job = client.query(query=query, job_config=job_config)
    try:
        result = job.result()  
    except NotFound:
        return None
    return result
def bq_query_table ( query , destination = None , write = 'WRITE_APPEND' ) : client = bq_client ( ) job_config = bigquery . QueryJobConfig ( destination = destination , write_disposition = write ) job = client . query ( query = query , job_config = job_config ) try : result = job . result ( ) except NotFound : return None return result
Query BigQuery table using SQL.
Query BigQuery table using SQL .
"""Query BigQuery table using SQL.""" # default append existing # wait for job to complete
query
destination
write