首页 文章

将AWS Lambda与计划事件一起使用时,递归Lambda函数已停止

提问于
浏览
0

使用计划的AWS事件(也与cron作业选项一起使用)调用时,我的递归lambda函数会停止 . 如果我使用lambda-dashboad或无服务器框架进行调用 - 一切正常 . lambda函数的持续时间超过6小时,当它从15-30分钟运行时被调用然后停止 . 在如何调用lambda函数之间有区别吗?我在哪里可以找到这种行为的解释?

LAMBDA-METHOD -> invokeLambda(lambdaname, payload) { // eslint-disable-line class-methods-use-this
    const req = {
      FunctionName: lambdaname,
      InvocationType: 'Event',
      Payload: JSON.stringify(payload),
    };

    const lambda = new aws.Lambda({
      region: 'us-east-1',
    });

    console.log(`[INFO - LAMBDA - ${lambdaname.toUpperCase()}] ${JSON.stringify(payload)}`);
    return lambda.invoke(req).promise();
  }
...
const createInstance = (Gapi, Parser, Lambda, Config) => {
  const gapi = new Gapi(Config);
  const parser = new Parser(gapi, Config);
  return new Lambda(gapi, parser, Config);
};
...
exports.sync_contacts = async (event, context) => {
    // create clear instance of class
    const Lambda = createInstance(GAPI, PARSER, LAMBDA, CONFIG); 
    // util for handle 5min limit lambda :use context.getRemainingTimeInMillis()
    const middleware = Ware(); 
    // return result off work after 5 min (worked 4.5 min then give 0.5 for refresh)
    const nextRefresh = await refresh(Lambda, middleware)(event, context);
    if (typeof nextRefresh === 'string') return nextRefresh;
    // recursive invoked
    if (nextRefresh.type === 'REFRESH') {
        return Lambda.invokeLambda(
            context.functionName,
            nextRefresh,
        );
    }
    // recursive invoked
    if (nextRefresh.type === 'DONE') {
        Lambda.token = nextRefresh.token;
        const [err, token] = await Lambda.tokenStep('NEXT');
        if (err) return err;
        if (token) {
            return Lambda.invokeLambda(
                context.functionName,
                { type: 'INIT', payload: { lastIndex: 0, token } },
            );
        }
    }
    // finish
    return '[LAMBDA - GLOBAL - DONE]';
};

1 回答

  • 0

    问题出在 memorySize 参数的设置中 . 当我第一次运行脚本时,数据很小,默认的128 MB足以完成任务 . 在下一次启动时,数据量很大,这就是为什么我必须增加到512 MB . 我希望根据我使用递归lambda函数的经验,有人会很有用 .

相关问题