def _streaming_insert(self, rows):
    table_data = self.service.tabledata()
    body = self._build_request_body_from_rows(rows)
    response = table_data.insertAll(projectId=self.project_id, datasetId=self.dataset_id, tableId=self.table_id, body=body).execute()
    return response
def _streaming_insert(self, rows):
    table_data = self.service.tabledata()
    body = self._build_request_body_from_rows(rows)
    response = table_data.insertAll(projectId=self.project_id, datasetId=self.dataset_id, tableId=self.table_id, body=body).execute()
    return response