AWS Lambdaを用いて複数DBからデータを取得するAPIを作りたい

Question

実現したいこと

複数DBを検索して、データを取得するAPIを作りたい

そのために、下記のプログラムについてアドバイスいただければと思います

環境

AWS Lambda: Node.js 6.10
データベース: DynamoDB

現状

お世話になります。

Node.jsを用いて、APIを開発しております。
複数のDynamoDBに存在するデータを検索したいのですが、うまくいっておりません。

var AWS = require("aws-sdk");
var dynamo = new AWS.DynamoDB.DocumentClient();
var tableName = "データベース";
var common = require("インポートファイル");

exports.handler = (event, context, callback) => {
    var response = common.response();
    if (!event.queryStringParameters) // クエリの入力判定処理
    if (!event.queryStringParameters.uid) // クエリの入力判定処理

    var param1 = {
        "TableName": tableName,
        ProjectionExpression: "取得するデータ",
        FilterExpression: "判定条件",
        ExpressionAttributeNames: {
            // 変数を置換
        },
        ExpressionAttributeValues: {
        }
    };

    dynamo.scan(param1, function(err1, data1) {
        if (err1) {
            response.statusCode = 500;
            response.body = JSON.stringify({
                "message": err1
            });
        } else {
            var result = [];
            if (data1.Items) {
                data1.Items.forEach(function(val) {
                    var param2 = {
                        "TableName": "データベース名",
                        ProjectionExpression: "取得する変数",
                        FilterExpression: "判定条件",
                        ExpressionAttributeNames: {
                             // 変数を置換
                        },
                        ExpressionAttributeValues: {   
                        }
                    };
                    console.log(param2);
                    dynamo.scan(param2, function(err2, data2) {
                        console.log(data2);
                        if (err2) {
                            response.statusCode = 500;
                            response.body = JSON.stringify({
                                "message": err2
                            });
                        } else {
                            console.log(data2.Items);
                            result[result.length] = data2.Items;
                        }
                        return;
                    });
                });
                response.body = JSON.stringify(result);
                callback(null, response);
                return;
            }
        }
    });
};

上記のプログラムを実行すると、dynamodb.scan (param2直前の

console.log(param2);

では、正しい結果が得られているのですが、dynamodb.scan (param2直後の

console.log(data2);

では、何も結果が返ってきません。。。

(そもそもデータがないわけではなく、判定条件も間違ってないと思われます。
スキャン数はデータベースのデータ数とも一致しております。)

上記のプログラムにに間違っている箇所があれば教えていただきたいです。
また、より良い実装があれば、アドバイスが欲しいです。

よろしくお願いします。

Answer 1

dynamodb.scan は非同期処理なので、ちゃんと取り回しをしてあげなければいけません。
上記のソースコードだと、2回目の dynamodb.scan の処理が終わる前に console.log が実行されていると思われます。

現在LambdaはNode.js8.10が使用できるので、 async/await を使えば割と簡単に実現できます。

Comments

[r-kurokw]

ご回答いただきまして、誠にありがとうございます。
当方でもいろいろ調べてみたのですが、仰る通り非同期処理が悪さしているようですね。
Promiseを用いることで、同期処理のように扱うことができ、無事に解決しました。

また、ryo-isさんが仰るようにasync/awaitを用いることで、Promiseよりもコードが簡潔に書くことができ、同期処理を実現できそうですので、こちらの方法も試してみようと思います。
ありがとうございました。