подключиться к другой учетной записи AWS Kinesis и поставить записи из MQ - PullRequest
Новая
       14

подключиться к другой учетной записи AWS Kinesis и поставить записи из MQ

0 голосов
/ 29 ноября 2018

Ниже приведен код, который должен подключаться к другой учетной записи AWS Kinesis и помещать записи из AWS MQ. 

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'
        )

Журналы ошибок: - 

{
  "errorMessage": "An error occurred (AccessDeniedException) when calling the PutRecord operation: User: arn:aws:iam::349928753634:user/svc.caspian-ingestion.onepurchase-uki-bookings-kinesis-test is not authorized to perform: kinesis:PutRecord on resource: arn:aws:kinesis:eu-central-1:349928753634:stream/CaspianStream_Onepurchase_UKI_bookings",
  "errorType": "ClientError",
  "stackTrace": [
    [
      "/var/task/op_worker.py",
      17,
      "lambda_handler",

Моя политика: - 

{
    "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"
            ]
        }
    ]
}

Есть ли возможность, когда мы можем передать детали Арн во время сеанса и отправить записи

...