Estoy desarrollando un AWS Lambda en TypeScript que usa Axios para obtener datos de una API y esos datos se filtrarán y se colocarán en un dynamoDb.
El código se ve de la siguiente manera:
export {}; const axios = require("axios"); const AWS = require('aws-sdk'); exports.handler = async (event: any) => { const shuttleDB = new AWS.DynamoDB.DocumentClient(); const startDate = "2021-08-16"; const endDate = "2021-08-16"; const startTime = "16:00:00"; const endTime = "17:00:00"; const response = await axios.post('URL', { data:{ "von": startDate+"T"+startTime, "bis": endDate+"T"+endTime }}, { headers: { 'x-rs-api-key': KEY } } ); const params = response.data.data; const putPromise = params.map(async(elem: object) => { delete elem.feat1; delete elem.feat2; delete elem.feat3; delete elem.feat4; delete elem.feat5; const paramsDynamoDB = { TableName: String(process.env.TABLE_NAME), Item: elem } shuttleDB.put(paramsDynamoDB).promise(); }); await Promise.all(putPromise); }; Todo esto funciona bastante bien. Si se presiona el botón de prueba la primera vez, todo parece estar bien y funciona. Por ejemplo, recibí todos los console.log s durante el desarrollo, pero los datos no se colocan en la base de datos .
Con el segundo intento, es el mismo resultado, pero los datos se colocan con éxito en la base de datos.
¿Alguna idea con respecto a este tema? ¿Cómo puedo resolver este problema y poner los datos en la base de datos después del primer intento?
¡Gracias por adelantado!
necesita devolver la promesa de la llamada db -
return shuttleDB.put(paramsDynamoDB).promise(); Además, Promise.all se completará antes si alguna llamada falla (en comparación con Promise.allSettled), por lo que puede valer la pena cerrar la sesión de cualquier error que pueda estar ocurriendo también.
Mejor aún, eche un vistazo a transactWrite: https://docs.aws.amazon.com/AWSJavaScriptSDK/latest/AWS/DynamoDB/DocumentClient.html#transactWrite-property para asegurarse de que se escribe todo o nada.