如何知道 lambda 函数本身的事件源答案

【问题标题】：How to know event souce of lambda function in itself如何知道 lambda 函数本身的事件源
【发布时间】：2017-06-08 11:00:33
【问题描述】：

想知道函数中lambda函数的事件源。

我想做的是使用某个 AWS 服务（CloudWatch、S3、Step 函数等）中的一个 lambda 函数，并根据服务更改其行为。

上下文对象（函数的参数之一）包含关于 lambda 函数的信息，但不包含关于事件源的信息。

有办法知道吗？

【问题讨论】：

目前，我认为你不能，但即使你这样做了，如果它必须处理这样的多个事件源，你的 Lambda 函数将很难维护。如果您想拥有一个可扩展且可维护的应用程序，则为每个事件源提供一个单独的函数会更好。
@KhalidT。谢谢你的建议。

标签： amazon-web-services aws-lambda

【解决方案1】：

如果您已使用 API 将 Kinesis 或 DynamoDB 流确定为 Lambda 函数的事件源

aws lambda create-event-source-mapping

，那么你可以用

aws lambda list-event-source-mappings

如果您不这样做，那么您可以使用如下函数做出最佳猜测：

function getLambdaEventSource(event) {
    if (event.Records && event.Records[0].cf) return 'isCloudfront';

    if (event.configRuleId && event.configRuleName && event.configRuleArn) return 'isAwsConfig';

    if (event.Records && (event.Records[0].eventSource === 'aws:codecommit')) return 'isCodeCommit';

    if (event.authorizationToken === "incoming-client-token") return 'isApiGatewayAuthorizer';

    if (event.StackId && event.RequestType && event.ResourceType) return 'isCloudFormation';

    if (event.Records && (event.Records[0].eventSource === 'aws:ses')) return 'isSes';

    if (event.pathParameters && event.pathParameters.proxy) return 'isApiGatewayAwsProxy';

    if (event.source === 'aws.events') return 'isScheduledEvent';

    if (event.awslogs && event.awslogs.data) return 'isCloudWatchLogs';

    if (event.Records && (event.Records[0].EventSource === 'aws:sns')) return 'isSns';

    if (event.Records && (event.Records[0].eventSource === 'aws:dynamodb')) return 'isDynamoDb';

    if (event.records && event.records[0].approximateArrivalTimestamp) return 'isKinesisFirehose';

    if (event.records && event.deliveryStreamArn && event.deliveryStreamArn.startsWith('arn:aws:kinesis:')) return 'isKinesisFirehose';

    if (event.eventType === 'SyncTrigger' && event.identityId && event.identityPoolId) return 'isCognitoSyncTrigger';

    if (event.Records && event.Records[0].eventSource === 'aws:kinesis') return 'isKinesis';

    if (event.Records && event.Records[0].eventSource === 'aws:s3') return 'isS3';

    if (event.operation && event.message) return 'isMobileBackend';

}

我说这是一个最佳猜测，因为像 API 网关请求这样的事件源可能会发送任何东西。如果您确定不会遇到这种情况，那么上面的函数可以解决问题。

【讨论】：