首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >AWS Lambda执行15-20秒,将遥测事件发送到Azure应用程序Insight

AWS Lambda执行15-20秒,将遥测事件发送到Azure应用程序Insight
EN

Stack Overflow用户
提问于 2018-09-14 04:25:19
回答 2查看 191关注 0票数 0

我需要在云监视日志组记录到日志组时将日志从云监视日志组发送到Application实例。我试图通过添加一个云监视日志组来实现这一点,作为我的Lambda的触发器,而在Lambda内部,我使用应用程序洞察力库将事件发送到一个AI实例。

当我的lambda的默认执行超时为3秒时,我无法在我的AI实例中看到任何日志,我的lambda成功地执行并在2-3秒内终止。当我将超时时间增加到20秒时,我可以看到在AI中填充了日志,而我的lambda执行了15-17秒。

我的理解是,AI遥测客户端将数据分批发送并暂时存储在磁盘上,直到发送为止。当lambda的资源在其执行后退役时,我可能会失去这些事件,因为它们可能还没有被排除。

如何确保AI遥测客户端不批量处理这些事件,并在收到这些事件后立即发送?

下面是我的Lambda代码

代码语言:javascript
运行
复制
exports.handler = (event, context, callback) => {
    var zlib = require("zlib");
    var appInsights = require("applicationinsights");

    appInsights.setup("<My Subscription Key>").setUseDiskRetryCaching(false);;
    var client = appInsights.defaultClient;
    // TODO implement
    var payload = new Buffer.from(event.awslogs.data, 'base64');

    zlib.gunzip(payload, function(err, dezipped) {
        if (!err) {
            client.trackEvent({ name: dezipped.toString() });
        }
    });

    client.flush(); 
};

为了实现我的目标,我还应该遵循其他的方法或最佳实践吗?

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2018-09-20 09:42:34

只有当我的lambda在上一次调用后间隔几分钟后执行时,我才能看到这种行为。我试着以1秒的间隔连续运行lambda,我可以看到,只有第一个请求花费了那么多时间,随后的请求平均不超过400毫秒。这是因为对于第一个lambda执行请求,AWS需要一些时间来委托资源并使用相同的资源,如果这个lambda是在第一个调用后被快速调用的。

看来我的理解是,“lambda的资源被退役后,它的执行”是不完整的。

票数 0
EN

Stack Overflow用户

发布于 2018-09-14 05:56:20

你失踪了,

代码语言:javascript
运行
复制
context.callbackWaitsForEmptyEventLoop = false;

在你的密码里。

请在立即输入函数后添加此内容,并使用响应调用回调以退出进程。

修改后的代码是:

代码语言:javascript
运行
复制
    exports.handler = (event, context, callback) => {
    context.callbackWaitsForEmptyEventLoop = false;
    var zlib = require("zlib");
    var appInsights = require("applicationinsights");

    appInsights.setup("<My Subscription Key>").setUseDiskRetryCaching(false);;
    var client = appInsights.defaultClient;
    // TODO implement
    var payload = new Buffer.from(event.awslogs.data, 'base64');

    function gunzipcomplete() { 
         client.flush();
         callback(null, done);
    }

    zlib.gunzip(payload, function(err, dezipped) {
        if (!err) {
            client.trackEvent({ name: dezipped.toString() });
        }
        gunzipcomplete();  // this is a complete.
    });



};

希望这能有所帮助。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/52324969

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档