Entonces, en mi aplicación, estoy analizando cron varios datos de la base de datos y lo tengo ahora mismo donde creo una ejecución constante para cada dato para encontrar el dag_id y probar el determineCron uno a la vez manualmente. ¿Cómo haría una matriz para que "determineCron ()" en la parte inferior probará cada ejecución en lugar de codificar manualmente determineCron (ejecutar), determineCron (ejecutar2), determineCron (ejecutar3), determineCron (ejecutar4), etc.
const run = { start_date: '2022-07-01T13:45:01.221636+00:00', end_date: '2022-07-01T14:11:01.864293+00:00', state: 'success', dag_run_id: 'scheduled__2022-06-30T13:45:00+00:00', dag_id: 'IPP_CYCLE_PARMS', } const run2 = { start_date: '2022-06-26T23:00:00.742495+00:00', end_date: '2022-06-27T14:10:23.108401+00:00', state: 'failed', dag_run_id: 'scheduled__2022-06-25T23:00:00+00:00', dag_id: 'EFS-Winning-Route-daily-batch' } async function determineCron(result){ /*dagID = result?.[0]?.dag_id || 0*/ dagID = result ? result.dag_id : 0 console.log(dagID) job = await bqConnection().query(`SELECT * FROM \`np-inventory-planning-thd.IPP_SLA.expected_sla\` where dag_id = "${dagID}"`) console.log(job[0][0]); cronTime = job[0][0].cron_time var interval = parser.parseExpression(cronTime); console.log('Date: ', interval.next().toString()); } determineCron(run) determineCron(run2)const runs = [ { start_date: '2022-07-01T13:45:01.221636+00:00', end_date: '2022-07-01T14:11:01.864293+00:00', state: 'success', dag_run_id: 'scheduled__2022-06-30T13:45:00+00:00', dag_id: 'IPP_CYCLE_PARMS', }, { start_date: '2022-06-26T23:00:00.742495+00:00', end_date: '2022-06-27T14:10:23.108401+00:00', state: 'failed', dag_run_id: 'scheduled__2022-06-25T23:00:00+00:00', dag_id: 'EFS-Winning-Route-daily-batch' } ] runs.forEach(determineCron)Coloque sus ejecuciones en una matriz y luego use array.forEach, así:
interface CronRun { start_date: string; end_date: string; state: string; dag_run_id: string; dag_id: string; } const runs: CronRun[] = [ { start_date: '2022-07-01T13:45:01.221636+00:00', end_date: '2022-07-01T14:11:01.864293+00:00', state: 'success', dag_run_id: 'scheduled__2022-06-30T13:45:00+00:00', dag_id: 'IPP_CYCLE_PARMS', }, { start_date: '2022-06-26T23:00:00.742495+00:00', end_date: '2022-06-27T14:10:23.108401+00:00', state: 'failed', dag_run_id: 'scheduled__2022-06-25T23:00:00+00:00', dag_id: 'EFS-Winning-Route-daily-batch' } ]; async function determineCron(result: ChronRun){ /*dagID = result?.[0]?.dag_id || 0*/ dagID = result ? result.dag_id : 0 console.log(dagID) job = await bqConnection().query(`SELECT * FROM \`np-inventory-planning-thd.IPP_SLA.expected_sla\` where dag_id = "${dagID}"`) console.log(job[0][0]); cronTime = job[0][0].cron_time var interval = parser.parseExpression(cronTime); console.log('Date: ', interval.next().toString()); } runs.forEach(determineCron);como su código original, esto los ejecutará todos en paralelo. Si los quieres en serie tendrás que hacer
for await (const run of runs) { determineCron(run); }en cambio.
Podría crear una matriz con las referencias de las constantes, pero es complicado después de eso, porque si usa cualquier método de matriz integrado como map, forEach, reduce... para ejecutar la función, no esperará al final anterior para ejecutarse. la próxima llamada Por lo tanto, lo que debes hacer es usar for y sus respectivas variaciones..
// if you are in a async scope you can remove that self invoked function (async function () { const runs = [ { start_date: "2022-07-01T13:45:01.221636+00:00", end_date: "2022-07-01T14:11:01.864293+00:00", state: "success", dag_run_id: "scheduled__2022-06-30T13:45:00+00:00", dag_id: "IPP_CYCLE_PARMS", }, { start_date: "2022-06-26T23:00:00.742495+00:00", end_date: "2022-06-27T14:10:23.108401+00:00", state: "failed", dag_run_id: "scheduled__2022-06-25T23:00:00+00:00", dag_id: "EFS-Winning-Route-daily-batch", }, ]; async function determineCron(result) { /*dagID = result?.[0]?.dag_id || 0*/ dagID = result ? result.dag_id : 0; console.log(dagID); job = await bqConnection().query( `SELECT * FROM \`np-inventory-planning-thd.IPP_SLA.expected_sla\` where dag_id = "${dagID}"` ); console.log(job[0][0]); cronTime = job[0][0].cron_time; var interval = parser.parseExpression(cronTime); console.log("Date: ", interval.next().toString()); } for (let run of runs) { await determineCron(run); } })();