in infra-as-code/modules/export-to-bq-incremental/function-source-code/lib.py [0:0]
def __init__(
self,
ccai_insights_project_id,
ccai_insights_location_id,
bigquery_project_id,
bigquery_staging_dataset,
bigquery_staging_table,
bigquery_final_dataset,
bigquery_final_table
):
self.ccai_insights_project_id = ccai_insights_project_id
self.ccai_insights_location_id = ccai_insights_location_id
self.bigquery_project_id = bigquery_project_id
self.bigquery_staging_dataset = bigquery_staging_dataset
self.bigquery_staging_table = bigquery_staging_table
self.bigquery_final_dataset = bigquery_final_dataset
self.bigquery_final_table = bigquery_final_table
self.bq_client = bigquery.Client()
self.staging_table_id = f'{self.bigquery_project_id}.{self.bigquery_staging_dataset}.{self.bigquery_staging_table}'
self.final_table_id = f'{self.bigquery_project_id}.{self.bigquery_final_dataset}.{self.bigquery_final_table}'
self.insights_url_with_location = ( self.INSIGHTS_BASE_URL
+ f'/projects/{self.ccai_insights_project_id}/locations/{self.ccai_insights_location_id}')