SELECT resource_type, TO_JSON_STRING(labels) as labels, cost as cost FROM `project.dataset.table`;
SELECT TO_JSON_STRING(labels) as labels, sum(cost) as cost FROM `project.dataset.table` GROUP BY labels;
SELECT FORMAT_TIMESTAMP("%E4Y%m%d", _PARTITIONTIME) as date, COUNT(order_id) AS total_orders, order_location as location FROM usage.orders_partitioned WHERE _PARTITIONTIME >= TIMESTAMP_SUB(CURRENT_TIMESTAMP(), INTERVAL 180 DAY) AND _PARTITIONTIME < TIMESTAMP_TRUNC(CURRENT_TIMESTAMP(), DAY) AND order_status IN ("COMPLETE") GROUP BY date, location
SELECT FORMAT_TIMESTAMP("%E4Y%m%d", _PARTITIONTIME) as date, COUNT(order_id) AS total_orders, order_location as location FROM usage.orders_partitioned WHERE _PARTITIONTIME >= TIMESTAMP_SUB(CURRENT_TIMESTAMP(), INTERVAL 1 DAY) AND _PARTITIONTIME < TIMESTAMP_TRUNC(CURRENT_TIMESTAMP(), DAY) AND order_status IN ("COMPLETE") GROUP BY date, location
def AsyncQuery(self, select_query, billing_projectId, dataset_projectId, datasetId, destination_tableId): query_request = self.bigquery_service.jobs() query_config = { 'jobReference': { 'projectId': billing_projectId, 'jobId': str(uuid.uuid4()) }, 'configuration': { 'query': { 'query': select_query, 'priority': 'BATCH', 'useLegacySql': 'false', 'writeDisposition': 'WRITE_APPEND', 'destinationTable': { 'datasetId': datasetId, 'projectId': dataset_projectId, 'tableId': destination_tableId } } } } query_response = query_request.insert( projectId=projectId, body=query_config). execute() return query_response
cron: - description: 'Load task for report tables' url: / schedule: every 24 hours
