Обещания при передаче функции в качестве параметра

Question

Я понимаю, как большей частью работают обещания, но у меня много трудностей с пониманием того, как с ними обращаться, когда мне нужно передать функцию в качестве параметра:

var promise = new Promise(function(resolve, reject) {
    // Do async job
    ec2.describeInstances(function(err, data) {
        console.log("\nIn describe instances:\n");
        var list = [];
        if (err) reject(err); // an error occurred
        else {
            var i = 0 ;
            //console.log(data.Reservations);
            var reservations = data.Reservations;
            for (var i in reservations) {
                var instances = reservations[i]['Instances'];
                var j = 0;
                //console.log(JSON.stringify(instances, null, 2));
                for (j in instances){
                    var tags = instances[j]
                    var k = 0;
                    var instanceId = tags['InstanceId'];
                    var tag = tags['Tags'];
                    var l;
                    //console.log(tag);

                    for (l in tag){
                        //console.log(instanceId);
                        //console.log(tag[l]['Value']);
                        if (String(tag[l]['Value']) == '2018-10-15T23:45' || String(tag[l]['Key']) == 'killdate') {

                            console.log(tag[l]['Key'] + ' ' + tag[l]['Value']);
                            list.push(instanceId);
                            console.log(list);

                            //return(list);
                        }
                    }
                }
            }       
        resolve(list);
        }
    });

});

promise.then(function (list) {
    ec2.terminateInstances(list, function(err, data) {
        if (err) console.log(err, err.stack); // an error occurred
        else     console.log("made it");  });
});

до того, как у меня былПервая часть кода как:

return new Promise(function(resolve, reject) { ... }

, и это работало для первой части, но как только я изменил его на «var» и добавил новое обещание внизу, он перестал работать.(править) Когда я имею в виду «перестал работать», я имею в виду, что ни одна из двух функций не запускается, то есть: он завершает обработчик до завершения любой из функций и ни одного из операторов возврата или журналов консоли.

Любая помощь будет принята с благодарностью!

Спасибо!

Answer 1

Я в конечном итоге это исправить.Извините, забыл опубликовать, прежде чем я добавил в части SNS.В итоге я узнал много о функциональном программировании и решил использовать функцию await вместо сложного синтаксиса обещаний.Ниже приведен код:

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

    const AWS  = require('aws-sdk');
    const date = new Date().toISOString().substr(0, 16)
    const ec2  = new AWS.EC2();
    var sns = new AWS.SNS();

    console.log("date is: " + date)
    console.log(date.length);

    const params = {
            TopicArn:'arn:aws:sns:us-east-1:503782973686:test',
            Message:'Success!!! ',
            Subject: 'TestSNS'
        }

    const describeResult = await ec2.describeInstances().promise()

    const terminatableInstances = await describeResult
        .Reservations
        .reduce((acc, reservation) => acc.concat(reservation.Instances), [])
        //'2018-10-15T23:45'
        .map((instance) => {
            //console.log(instance)
            //console.log(instance.Tags)
            var date = instance.Tags
            .filter(tag => tag.Key == 'killdate' && tag.Value == date) //date should be in this format on tag: 2018-10-15T23:45
            .reduce((acc, curr) => curr.Value, null);
            if (date != null) {
                return instance.InstanceId;
            }
            return null;
        })
        .filter(id  => id != null)


    console.log(terminatableInstances);

    const snsPush = await ec2.terminateInstances({
        InstanceIds: terminatableInstances,
        //DryRun: true //set this flag if you want to do a dry run without terming instances
    }, (err, data) => {

        if (err) {
            console.log('no instances to terminate!')
        }
        else {
            console.log('terminated instances')
        }

    })

    console.log(snsPush)
    //return(snsPush).promise()
    return sns.publish(params, (err, data) => {
        if (err) {
            console.log(err, err.stack); 
        }
        else {
             console.log('sent');
        }
        }).promise(); 


};

Answer 2

я предлагаю разбить вашу логику - вам будет проще справиться с результатом, которого вы хотите достичь.

На мой взгляд, правильный путь:

функция обещания (сервисная функция):

 function myAsyncFunction(url) {
    return new Promise((resolve, reject) => {
        result = () => resolve(data);
        fail = () => reject(err);
    });
}

тогда ваш абонент обещает:

myAsyncFunction().then(dataHandler(result), // "promise worked!"
    function (err) {// Error: "It broke"
        console.log(err)
    });

тогда логика:

    function dataHandler(data) { /* data logic */}

удачи

Answer 3

var promise = Promise.resolve();

promise
    .then(function() {
        return ec2.describeInstances(function(err, data) {
            var list = [];
            if (err) throw err; // an error occurred
            // else logic
        })
    })
    .catch(/* if needed here */)
    .then(function (list) {
        return ec2.terminateInstances(list, function(err, data) {
            if (err) console.log(err, err.stack); // an error occurred
            else     console.log("made it");  });
    })
    .catch(/* if needed here */)

Answer 4

Интересно, будет ли что-то подобное работать:

var promise = Promise.resolve(function() {
    return ec2.describeInstances...
})

promise
    .then(/* handle successful promise resolution */ )
    .catch(/* handle promise rejection */ )