asyncの戻り値がobject Promiseになってしまう

Question

前提・実現したいこと

dynamoDBのクエリをlambdaで受けとりたいです。

発生している問題・エラーメッセージ

async関数list_albumsを作りDBから値を取得することはできました。
呼び出し元に値をreturnすると[object Promise]になってしまいます。
どのようにすればreturnを正常な値として受け取れるでしょうか？

result=[object Promise]

該当のソースコード

exports.list_albums =async function(body,context){
    var params = {
        TableName: 'albums',
        ExpressionAttributeNames:{
            '#u': 'uniqueid'},
        ExpressionAttributeValues:{
            ':val_1': global.userId,
        },
        KeyConditionExpression: '#u = :val_1'
    };

    var result =await doQuery(params);
    console.log('check3='+result);
    return result;
};

function doQuery(parameter) {
    return new Promise((resolve, reject) => {
        docClient.query(parameter, (err, data) => {
            if (err) {
                console.log('[ERROR] DynamoDB Query Error: ', err);
                reject(err);
            } else {
                var arrstr ='';
                data.Items.forEach(function(album, index){
                    console.log(album.title);
                    arrstr = arrstr + album.title +"\n";
                    console.log('check1='+arrstr);
                });
                resolve(arrstr);
            }
        });
    });
}

//呼び出し元
var result =db_control.list_albums(body,context);
console.log('result='+ result); //ここが[object Promise]になる

試したこと

呼び出し元をasyncにして、呼び出しを

await db_control.list_albums(body,context);

追記

"use strict";
var AWS = require('aws-sdk');
var contents_get = require('./get_contents');
var db_control = require('./db_control');

const crypto = require("crypto");
AWS.config.region = 'ap-northeast-1';

global.messageid;
global.userId;
exports.handler = async function (event, context) {
  let body = JSON.parse(event.body);
  let signature = crypto
    .createHmac("sha256", process.env.CHANNELSECRET)
    .update(event.body)
    .digest("base64");
  let checkHeader = (event.headers || {})["X-Line-Signature"];

  if (signature === checkHeader) {
    if (body.events[0].replyToken === "00000000000000000000000000000000") {   
      let lambdaResponse = {
        statusCode: 200,
        headers: { "X-Line-Status": "OK" },
        body: '{"result":"connect check"}',
      };
      context.succeed(lambdaResponse);
      // ③接続確認エラーを確認する。

    } else {
       body.events.forEach(function(eve) {
        global.messageid =eve.message.id;
        global.userId =eve.source.userId;
        if (eve.message.text === 'アルバム'){
            global.userId =eve.source.userId;
            var result =await db_control.list_albums(body);  //ここのawaitがエラーになる
            console.log('result='+ result);
        }
        
    });
    }
  } else {
    console.log("署名認証エラー");
  }
};

としてみたのですが、これはエラー(unexpectedtoken)で通りませんでした。

Comments

[退会済みユーザー]

呼び出し元をasyncにして、呼び出しを
await db_control.list_albums(body,context);
としてみたのですが、これはエラー(unexpectedtoken)で通りませんでした。

コードの一部だけ提示されてもなぜエラーになるのは判別できないので、全体を提示してください。

[rirako]

コメントありがとうございます。
試してみた部分のコードを追記しました。
何かアドバイスなどありましたらよろしくお願いします。

Answer 1

forEachの中のコールバック関数もasync関数にしてください。

"use strict";
var AWS = require('aws-sdk');
var contents_get = require('./get_contents');
var db_control = require('./db_control');

const crypto = require("crypto");
AWS.config.region = 'ap-northeast-1';

global.messageid;
global.userId;
exports.handler = async function (event, context) {
  let body = JSON.parse(event.body);
  let signature = crypto
    .createHmac("sha256", process.env.CHANNELSECRET)
    .update(event.body)
    .digest("base64");
  let checkHeader = (event.headers || {})["X-Line-Signature"];

  if (signature === checkHeader) {
    if (body.events[0].replyToken === "00000000000000000000000000000000") {   
      let lambdaResponse = {
        statusCode: 200,
        headers: { "X-Line-Status": "OK" },
        body: '{"result":"connect check"}',
      };
      context.succeed(lambdaResponse);
      // ③接続確認エラーを確認する。

    } else {
--     body.events.forEach(function(eve) {
++     body.events.forEach(async function(eve) {
        global.messageid =eve.message.id;
        global.userId =eve.source.userId;
        if (eve.message.text === 'アルバム'){
            global.userId =eve.source.userId;
            var result =await db_control.list_albums(body);  //ここのawaitがエラーになる
            console.log('result='+ result);
        }

    });
    }
  } else {
    console.log("署名認証エラー");
  }
};

Comments

[rirako]

回答ありがとうございます。
無事、エラーをとることができました。

Answer 2

呼び出し元に値をreturnすると[object Promise]になってしまいます。

はい、async関数の返り値はPromiseになります。

どのようにすればreturnを正常な値として受け取れるでしょうか？

不可能です。Promiseが帰ってくることを前提に使うしかありません。

Comments

[rirako]

回答ありがとうございます。
戻り値を得る手段がないということはつまり、
『DBから値が返ってくるのを待つためにasyncを使う』という考え方が間違っているのでしょうか？
DBからの検索結果を待ってから処理を実行する手段はありますか？

[maisumakun]

> 『DBから値が返ってくるのを待つためにasyncを使う』という考え方が間違っているのでしょうか？

合っています。そのまま普通の値として同期的に使えないというだけです。

> DBからの検索結果を待ってから処理を実行する手段はありますか？

Promiseからthenでつなげる、あるいはawaitで受ける必要があります。

[rirako]

ありがとうございます。方向性がわかって安心しました。
理解不足のため、もう一度promiseの概要から調べなおしたいと思います。