我需要在云监视日志组记录到日志组时将日志从云监视日志组发送到Application实例。我试图通过添加一个云监视日志组来实现这一点,作为我的Lambda的触发器,而在Lambda内部,我使用应用程序洞察力库将事件发送到一个AI实例。
当我的lambda的默认执行超时为3秒时,我无法在我的AI实例中看到任何日志,我的lambda成功地执行并在2-3秒内终止。当我将超时时间增加到20秒时,我可以看到在AI中填充了日志,而我的lambda执行了15-17秒。
我的理解是,AI遥测客户端将数据分批发送并暂时存储在磁盘上,直到发送为止。当lambda的资源在其执行后退役时,我可能会失去这些事件,因为它们可能还没有被排除。
如何确保AI遥测客户端不批量处理这些事件,并在收到这些事件后立即发送?
下面是我的Lambda代码
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();
};
为了实现我的目标,我还应该遵循其他的方法或最佳实践吗?
发布于 2018-09-20 09:42:34
只有当我的lambda在上一次调用后间隔几分钟后执行时,我才能看到这种行为。我试着以1秒的间隔连续运行lambda,我可以看到,只有第一个请求花费了那么多时间,随后的请求平均不超过400毫秒。这是因为对于第一个lambda执行请求,AWS需要一些时间来委托资源并使用相同的资源,如果这个lambda是在第一个调用后被快速调用的。
看来我的理解是,“lambda的资源被退役后,它的执行”是不完整的。
发布于 2018-09-14 05:56:20
你失踪了,
context.callbackWaitsForEmptyEventLoop = false;
在你的密码里。
请在立即输入函数后添加此内容,并使用响应调用回调以退出进程。
修改后的代码是:
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.
});
};
希望这能有所帮助。
https://stackoverflow.com/questions/52324969
复制相似问题