function uploadToBigQuery() {
// ID вашего проекта в Google Cloud
const projectId = 'technologicaltables';
// Идентификаторы Dataset и Table в BigQuery
const datasetId = 'Dispatcher';
const tableId = 'ExampleTable';
// Получение данных из Google Sheets
const sheet = SpreadsheetApp.getActiveSpreadsheet().getSheetByName('Исходные данные');
const data = sheet.getDataRange().getValues();
// Преобразование данных в формат JSON для вставки в BigQuery
let rows = [];
for (let i = 1; i < data.length; i++) { // Начинаем с 1, чтобы пропустить заголовок
let row = {
json: {
"название": data[i][0],
"статус": data[i][1]
}
};
rows.push(row);
}
// Логирование данных перед отправкой
Logger.log('Отправляемые данные: ' + JSON.stringify(rows));
// Формирование запроса на вставку данных
let insertAllRequest = {
rows: rows
};
// URL для вставки данных в таблицу BigQuery
const url = 'https://bigquery.googleapis.com/bigquery/v2/projects/' + projectId + '/datasets/' + datasetId + '/tables/' + tableId + '/insertAll';
// Опции запроса
const options = {
method: 'post',
contentType: 'application/json',
headers: {
Authorization: 'Bearer ' + ScriptApp.getOAuthToken()
},
payload: JSON.stringify(insertAllRequest),
muteHttpExceptions: true
};
// Выполнение запроса
let response = UrlFetchApp.fetch(url, options);
let result = JSON.parse(response.getContentText());
// Логирование полного ответа от BigQuery
Logger.log('Ответ от BigQuery: ' + JSON.stringify(result));
// Проверка на ошибки
if (result.insertErrors) {
for (let i = 0; i < result.insertErrors.length; i++) {
Logger.log('Ошибка: ' + result.insertErrors[i].errors[0].message);
}
} else {
Logger.log('Данные успешно загружены в BigQuery');
}
}
