AWS Kinesis Firehose non risponde a Lambda

Question

Ecco il codice Lambda:

const AWS = require('aws-sdk');
var firehose = new AWS.Firehose({ region: 'ap-southeast-2' });

exports.handler = async (event, context) => {

var params = {
    DeliveryStreamName: 'TestStream', 
    Record: {
        Data: 'test data'
    }
};
console.log('params', params);

firehose.putRecord(params, function (err, data) {
    if (err) console.log(err, err.stack); // an error occurred
    else console.log('Firehose Successful',  data);           // successful response
});

}

E la politica è:

{
"Version": "2012-10-17",
"Statement": [
    {
        "Effect": "Allow",
        "Action": [
            "firehose:DeleteDeliveryStream",
            "firehose:PutRecord",
            "firehose:PutRecordBatch",
            "firehose:UpdateDestination"
        ],
        "Resource": [
            "arn:aws:firehose:ap-southeast-2:xxxxxxxxxxxxx:deliverystream/TestStream"
        ]
    }
]

}

Ho letteralmente tagliato tutto il resto. E la risposta che vedo in cloudwatch è:

2020-11-05T18:08:17.564+13:00   START RequestId: 3bed96b1-54af-4b08-bc06-be3732bba9ea Version: $LATEST

2020-11-05T18:08:17.568+13:00   2020-11-05T05:08:17.567Z 3bed96b1-54af-4b08-bc06-be3732bba9ea INFO params { DeliveryStreamName: 'TestStream', Record: { Data: <Buffer 74 65 73 74 20 64 61 74 61> } }

2020-11-05T18:08:17.621+13:00   END RequestId: 3bed96b1-54af-4b08-bc06-be3732bba9ea

2020-11-05T18:08:17.621+13:00   REPORT RequestId: 3bed96b1-54af-4b08-bc06-be3732bba9ea Duration: 57.38 ms Billed Duration: 100 ms Memory Size: 960 MB Max Memory Used: 85 MB Init Duration: 399.22 ms

Quindi, l'esecuzione raggiunge le linee delle manichette e le supera senza fare nulla ...

Answer 1

Dal momento che stai utilizzando il gestore asincrono, penso che il problema sia che la tua funzione viene completata prima che il codice firehose abbia la possibilità di essere eseguito.

Un modo per correggere questo problema è attraverso l'uso di Promisecome mostrato nei documenti AWS . Per esempio:

const AWS = require('aws-sdk');
var firehose = new AWS.Firehose({ region: 'ap-southeast-2' });

exports.handler = async (event, context, callback) => {

    const promise = new Promise(function(resolve, reject) {

     var params = {
       DeliveryStreamName: 'TestStream', 
       Record: {
          Data: 'test data'
       }
     };
     console.log('params', params);

    firehose.putRecord(params, function (err, data) {
       if (err) console.log(err, err.stack); // an error occurred
       else console.log('Firehose Successful',  data);           //         successful response
     });
  })

  return promise;   
};

Le modifiche di cui sopra sono solo esemplari, quindi probabilmente saranno ancora necessari alcuni aggiustamenti.