Job Functionの設定

/**
 * 
 * @param {import("./types/job").JobRequest} jobRequest 
 * @param {import("./types/job").Context} context 
 */
const catalyst = require("zcatalyst-sdk-node");
const axios = require('axios');
const HOST = "https://newsapi.org";
const TABLENAME = [
	"HEADLINES",
	"BUSINESS",
	"ENTERTAINMENT",
	"HEALTH",
	"SCIENCE",
	"SPORTS",
	"TECHNOLOGY",
  ];
  const COUNTRY = "US";
  const APIKEY = "cc30ddcae1684e848f08ed474f6aaf0e";
  const DATASTORE_LOAD = 5;
  const pushNewstoDatastore = async ({ table, rowIds, articles }) => {
	return Promise.all(
	  articles.map(async (article, idx) => {
		const payload = {
		  title: article.title,
		  url: article.url,
		};
		if (rowIds.length === 0) {
		  //新しい行を挿入
		  return table.insertRow(payload);
		}
		return table.updateRow({ ...payload, ROWID: rowIds[idx] });
	  })
	);
  };
module.exports = async (jobRequest, context) => {
	try{
		console.log('Execution started');
		const catalystApp = catalyst.initialize(context);
		const zcqlAPI = catalystApp.zcql();
		const datastoreAPI = catalystApp.datastore();		
		const metaArr = await Promise.all(
			TABLENAME.map(async (table) => {
			  //NewsAPIへのリクエストパスを構築
			  let url = `${HOST}/v2/top-headlines?country=${COUNTRY}&apiKey=${APIKEY}`;
			  if (table !== TABLENAME[0]) {
			   url += "&category=" + table;
			  }
			  const response = await axios({
			   method: "GET",
			   url
			 });
		   let data = response.data;	   
			  //ZCQLを使用して行が存在するか確認
			  const queryResult = await zcqlAPI.executeZCQLQuery(
				`SELECT ROWID FROM ${table}`
			  );
			  return {
				table_name: table,
				table: datastoreAPI.table(table),
				zcql_response: queryResult,
				articles: data.articles.splice(0, 15),
			  };
			})
		  );
		  //DataStoreへの同期的な挿入/更新
		  for (const meta of metaArr) {
			let rowIds = [];
			while (meta.articles.length > 0) {
			  const chunk = meta.articles.splice(0, DATASTORE_LOAD);
			  if (meta.zcql_response.length > 0) {
				rowIds = meta.zcql_response
				  .splice(0, DATASTORE_LOAD)
				  .map((row) => row[meta.table_name].ROWID);
			  }
			  await pushNewstoDatastore({ ...meta, articles: chunk, rowIds });
			}
			console.log(
			  `${meta.table} table ${
				rowIds.length === 0 ? "inserted" : "updated"
			  } with current news'`
			);
		  }
		context.closeWithSuccess(); //アプリケーションの正常終了
	}catch(err){
		console.log("Error :: "+err);
		context.closeWithFailure(); //アプリケーションの異常終了
	};
};