连接到Kinesis的不同AWS帐户并从MQ放入记录

Question

我有下面的代码，应该连接到不同的AWS帐户的Kinesis和放置来自awsmq的记录。在

import time
import boto3
import json
from boto3 import Session

lambda_client = boto3.client('lambda')
kinesis_client = boto3.client('kinesis')

def lambda_handler(event, context):
    session = boto3.session.Session(aws_access_key_id= '', aws_secret_access_key= '',region_name='eu-aaa-1')
    kinesis_client = session.client('kinesis')
    print('received a message in worker : "%s"' % event)
    kinesis_client.put_record(
            StreamName='Stream_bookings',
            Data='event',
            PartitionKey='1'
        )

错误日志：-在

^{pr2}$

我的政策：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "kinesis:PutRecord",
                "lambda:InvokeAsync",
                "lambda:InvokeFunction"
            ],
            "Resource": [
                "arn:aws:kinesis:eu-central-1:1234566789:stream/Stream_bookings"
            ]
        }
    ]
}

我们是否有可能在会话下传递Arn详细信息并发送记录