def stream_row_to_bigquery(self, dataset_id, table_name, row, num_retries=5):
        insert_all_data = {
            'insertId': str(uuid.uuid4()),
            'rows': [{'json': row}]
        }
        self.logger.debug("BQ Data: {}".format(insert_all_data))

        table_result = self._bq.tabledata().insertAll(
            projectId=self.project_id,
            datasetId=dataset_id,
            tableId=table_name,
            body=insert_all_data).execute(num_retries=num_retries)

        self.logger.debug("BQ Insert: {}".format(table_result))

        return table_result
Sends data to bigquery
dataset/ETHPy150Open panoptes/POCS/panoptes/utils/google/bigquery.py/PanBigQuery.stream_row_to_bigquery