Function createBigQueryClientProvider

cli/api/dbadapters/bigquery.ts:42–61

(
  credentials: dataform.IBigQuery
)

export type BigQueryClientProvider = (projectId?: string) => BigQuery;

export function createBigQueryClientProvider(
  credentials: dataform.IBigQuery
): BigQueryClientProvider {
  const clients = new Map<string, BigQuery>();
  return (projectId?: string) => {
    projectId = projectId || credentials.projectId;
    if (!clients.has(projectId)) {
      clients.set(
        projectId,
        new BigQuery({
          projectId,
          scopes: EXTRA_GOOGLE_SCOPES,
          location: credentials.location,
          credentials: credentials.credentials && JSON.parse(credentials.credentials)
        })
      );
    }
    return clients.get(projectId);
  };
}

export class BigQueryDbAdapter implements IDbAdapter {
  private bigQueryCredentials: dataform.IBigQuery;