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 函数。

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

相关内容

热门资讯

6分钟学习!雀友会广东潮汕辅助... 6分钟学习!雀友会广东潮汕辅助,hhpoker免费辅助器,攻略教程(有挂方式)-哔哩哔哩运雀友会广东...
四分钟绝活儿!新道游正版辅助,... 四分钟绝活儿!新道游正版辅助,卡农辅助,2025版教程(有挂教程)-哔哩哔哩该软件可以轻松地帮助玩家...
2分钟诀窍!微友辅助器免费版v... 2分钟诀窍!微友辅助器免费版v3.0,川友汇挂牌,透牌教程(有挂教学)-哔哩哔哩1、微友辅助器免费版...
3分钟讲义!甘肃白银麻将辅助软... 3分钟讲义!甘肃白银麻将辅助软件,微信边锋辅助软件,靠谱教程(的确有挂)-哔哩哔哩1、玩家可以在甘肃...
三分钟诀窍!福建兄弟十三水辅助... 三分钟诀窍!福建兄弟十三水辅助器下载,欢乐茶馆辅助,揭秘教程(存在有挂)-哔哩哔哩一、福建兄弟十三水...
6分钟资料!摸一把游戏辅助软件... 6分钟资料!摸一把游戏辅助软件,小闲辅助神器,解密教程(真实有挂)-哔哩哔哩1、进入到摸一把游戏辅助...
第9分钟讲义!人海大厅辅助插件... 第9分钟讲义!人海大厅辅助插件,拱趴大菠萝修改器,爆料教程(有挂教学)-哔哩哔哩人海大厅辅助插件辅助...
3分钟教程书!新众乐辅助,情怀... 3分钟教程书!新众乐辅助,情怀娱乐辅助器,德州论坛(有挂存在)-哔哩哔哩1、首先打开情怀娱乐辅助器最...
十分钟资料!白银胡乐白银版辅助... 十分钟资料!白银胡乐白银版辅助,小程序边锋辅助,普及教程(有挂工具)-哔哩哔哩1、白银胡乐白银版辅助...
第四分钟策略!途游手游辅助脚本... 第四分钟策略!途游手游辅助脚本平台,海盗来了辅助器最新,wpk教程(有挂实锤)-哔哩哔哩1、每一步都...