a !f3*@sxdZddlmZddlmZddlmZddlmZddlm Z ddlm Z ddlm Z dd l m Z Gd d d eZd S) z4Client for interacting with the Google BigQuery API.) JSONClient) ConnectionDatasetCopyJobExtractTableToStorageJobLoadTableFromStorageJobQueryJob QueryResultsc@s`eZdZdZeZdddZddZdd Zdd d Z d d Z ddZ ddZ ddZ ddZdS)ClientaClient to bundle configuration needed for API requests. :type project: str :param project: the project which the client acts on behalf of. Will be passed when creating a dataset / job. If not passed, falls back to the default inferred from the environment. :type credentials: :class:`oauth2client.client.OAuth2Credentials` or :class:`NoneType` :param credentials: The OAuth2 Credentials to use for the connection owned by this client. If not passed (and if no ``http`` object is passed), falls back to the default inferred from the environment. :type http: :class:`httplib2.Http` or class that defines ``request()``. :param http: An optional HTTP object to make requests. If not passed, an ``http`` object is created that is bound to the ``credentials`` for the current object. FNcsvi}|rd|d<|dur ||d<|dur0||d<djf}jjd||d}fd d |d d D}||d fS)aList datasets for the project associated with this client. See: https://cloud.google.com/bigquery/docs/reference/v2/datasets/list :type include_all: boolean :param include_all: True if results include hidden datasets. :type max_results: int :param max_results: maximum number of datasets to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of datasets. If not passed, the API will return the first page of datasets. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.bigquery.dataset.Dataset`, plus a "next page token" string: if the token is not None, indicates that more datasets can be retrieved with another call (pass that value as ``page_token``). TallN maxResults pageTokenz/projects/%s/datasetsGETmethodpathZ query_paramscsg|]}t|qS)r from_api_repr.0resourceselfrW/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/bigquery/client.py Zsz(Client.list_datasets..datasetsr nextPageTokenproject connectionZ api_requestget)rZ include_all max_results page_tokenparamsrrespr!rrr list_datasets3s    zClient.list_datasetscCs t||dS)zConstruct a dataset bound to this client. :type dataset_name: str :param dataset_name: Name of the dataset. :rtype: :class:`gcloud.bigquery.dataset.Dataset` :returns: a new ``Dataset`` instance clientr)rZ dataset_namerrrdataset^s zClient.datasetcCsd|d}d|vrt||Sd|vr0t||Sd|vrDt||Sd|vrXt||StddS)a*Detect correct job type from resource and instantiate. :type resource: dict :param resource: one job resource from API response :rtype: One of: :class:`gcloud.bigquery.job.LoadTableFromStorageJob`, :class:`gcloud.bigquery.job.CopyJob`, :class:`gcloud.bigquery.job.ExtractTableToStorageJob`, :class:`gcloud.bigquery.job.QueryJob`, :class:`gcloud.bigquery.job.RunSyncQueryJob` :returns: the job instance, constructed via the resource configurationloadcopyextractqueryzCannot parse job resourceN)r rrr r ValueError)rrconfigrrrjob_from_resourceis    zClient.job_from_resourcec sddi}|dur||d<|dur(||d<|dur8||d<|durH||d<djf}jjd ||d }fd d |d dD}||dfS)aList jobs for the project associated with this client. See: https://cloud.google.com/bigquery/docs/reference/v2/jobs/list :type max_results: int :param max_results: maximum number of jobs to return, If not passed, defaults to a value set by the API. :type page_token: str :param page_token: opaque marker for the next "page" of jobs. If not passed, the API will return the first page of jobs. :type all_users: boolean :param all_users: if true, include jobs owned by all users in the project. :type state_filter: str :param state_filter: if passed, include only jobs matching the given state. One of * ``"done"`` * ``"pending"`` * ``"running"`` :rtype: tuple, (list, str) :returns: list of job instances, plus a "next page token" string: if the token is not ``None``, indicates that more jobs can be retrieved with another call, passing that value as ``page_token``). Z projectionfullNrrZallUsersZ stateFilterz/projects/%s/jobsrrcsg|]}|qSr)r6rrrrr sz$Client.list_jobs..jobsrr"r#) rr'r(Z all_usersZ state_filterr)rr*r8rrr list_jobss""    zClient.list_jobscGst||||dS)aConstruct a job for loading data into a table from CloudStorage. See: https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.load :type job_name: str :param job_name: Name of the job. :type destination: :class:`gcloud.bigquery.table.Table` :param destination: Table into which data is to be loaded. :type source_uris: sequence of string :param source_uris: URIs of data files to be loaded; in format ``gs:///``. :rtype: :class:`gcloud.bigquery.job.LoadTableFromStorageJob` :returns: a new ``LoadTableFromStorageJob`` instance r,r )rjob_name destinationZ source_urisrrrload_table_from_storageszClient.load_table_from_storagecGst||||dS)aQConstruct a job for copying one or more tables into another table. See: https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.copy :type job_name: str :param job_name: Name of the job. :type destination: :class:`gcloud.bigquery.table.Table` :param destination: Table into which data is to be copied. :type sources: sequence of :class:`gcloud.bigquery.table.Table` :param sources: tables to be copied. :rtype: :class:`gcloud.bigquery.job.CopyJob` :returns: a new ``CopyJob`` instance r,r)rr:r;sourcesrrr copy_tableszClient.copy_tablecGst||||dS)aConstruct a job for extracting a table into Cloud Storage files. See: https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.extract :type job_name: str :param job_name: Name of the job. :type source: :class:`gcloud.bigquery.table.Table` :param source: table to be extracted. :type destination_uris: sequence of string :param destination_uris: URIs of CloudStorage file(s) into which table data is to be extracted; in format ``gs:///``. :rtype: :class:`gcloud.bigquery.job.ExtractTableToStorageJob` :returns: a new ``ExtractTableToStorageJob`` instance r,r)rr:sourceZdestination_urisrrrextract_table_to_storageszClient.extract_table_to_storagecCst|||dS)aConstruct a job for running a SQL query asynchronously. See: https://cloud.google.com/bigquery/docs/reference/v2/jobs#configuration.query :type job_name: str :param job_name: Name of the job. :type query: str :param query: SQL query to be executed :rtype: :class:`gcloud.bigquery.job.QueryJob` :returns: a new ``QueryJob`` instance r,r )rr:r3rrrrun_async_queryszClient.run_async_querycCs t||dS)zRun a SQL query synchronously. :type query: str :param query: SQL query to be executed :rtype: :class:`gcloud.bigquery.query.QueryResults` :returns: a new ``QueryResults`` instance r,r)rr3rrrrun_sync_query s zClient.run_sync_query)FNN)NNNN)__name__ __module__ __qualname____doc__rZ_connection_classr+r.r6r9r<r>r@rArBrrrrrs +  7rN)rFZ gcloud.clientrZgcloud.bigquery.connectionrZgcloud.bigquery.datasetrZgcloud.bigquery.jobrr r r Zgcloud.bigquery.queryrrrrrrs