AWSLambda与AWSMSK触发器-角色和事件源必须与云函数位于同一帐户中。
创始人
2024-09-26 10:00:57
0

在AWS Lambda函数中使用AWS SDK for Python (boto3)设置Kafka事件源ARN和lambda执行角色ARN,如下所示:

import boto3

def lambda_handler(event, context):
    client = boto3.client('lambda')
    response = client.get_function_configuration(
        FunctionName='lambda-function-name'
    )
    arn = response['Role']
    
    client = boto3.client('kafka')
    response = client.list_clusters()
    cluster_arn = response['ClusterInfoList'][0]['ClusterArn']

    client = boto3.client('lambda')
    response = client.create_event_source_mapping(
        EventSourceArn=cluster_arn,
        FunctionName='lambda-function-name',
        Enabled=True,
        BatchSize=1,
        StartingPosition='LATEST',
        MaximumBatchingWindowInSeconds=60,
        BisectBatchOnFunctionError=True,
        DestinationConfig={
            'OnSuccess': {
                'Destination': 'arn:aws:logs:us-east-1:111122223333:destination:MyDestination'
            }
        },
        MaximumRecordAgeInSeconds=604800,
        MaximumRetryAttempts=10,
        ParallelizationFactor=1
    )

在此示例中,lambda-function-name 指的是 AWS Lambda 函数的名称,arnlambda-function-name 执行角色的 ARN,而 cluster_arn 是 Kafka 事件源 ARN。最后,使用 create_event_source_mapping 方法将事件源映射到 Lambda 函数。

要使此解决方法工作,确保角色和事件源都在同一帐户中。

相关内容

热门资讯

开挂辅助软件"德普之... 德普之星透视辅助软件下载是一款可以让一直输的玩家,快速成为一个“必胜”的ai辅助神器,有需要的用户可...
开挂辅助脚本"wpk... 开挂辅助脚本"wpk私人局辅助是真的吗"开挂(透视)辅助神器(存在有挂);打开点击测试直接进入微信(...
开挂辅助软件"wpk... 开挂辅助软件"wpk辅助是真的吗"开挂(透视)辅助工具(有挂技巧);无需打开直接搜索薇:136704...
开挂辅助平台"wep... 开挂辅助平台"wepoker钻石怎么看底牌"开挂(透视)辅助下载(有挂详细);wepoker钻石怎么...
开挂辅助神器"wep... 开挂辅助神器"wepoker数据分析"开挂(透视)辅助插件(详细教程)1、下载安装好wepoker数...
开挂辅助下载"哈糖大... 开挂辅助下载"哈糖大菠萝怎么开挂"开挂(透视)辅助软件(真的有挂) 【无需打开直接搜索加薇13670...
开挂辅助神器"xpo... 开挂辅助神器"xpoker透视辅助"开挂(透视)辅助安装(有挂透视);是一款可以让一直输的玩家,快速...
开挂辅助平台"约局吧... 开挂辅助平台"约局吧游戏挂"开挂(透视)辅助软件(的确有挂)【无需打开直接搜索加薇136704302...
开挂辅助下载"wpk... 开挂辅助下载"wpk有辅助器吗"开挂(透视)辅助插件(有挂总结)1、下载安装好wpk有辅助器吗,进入...
开挂辅助软件"wpk... 开挂辅助软件"wpk免费辅助"开挂(透视)辅助软件(有挂辅助)【无需打开直接搜索加薇13670430...