使用lambda函数将数据发送到kinesis流（在不同的AWS账户中）

我有一个写入kinesis流的lambda函数。但现在，我想写入属于不同AWS账户的kinesis流。假设我拥有所有必需的跨账户权限，如何将数据发送到此流？当我调用kinesis构造函数或putRecord函数时，应如何更改参数？使用lambda函数将数据发送到kinesis流（在不同的AWS账户中）

来源

2017-06-22 P parker

首先，你需要配置的Kinesis实例：

（我选择的JavaScript的例子）

var kinesis = new AWS.Kinesis({ 
    accessKeyId: 'XXX', 
    secretAccessKey: 'YYY', 
    region: 'eu-west-1', 
    apiVersion: '2013-12-02' 
});

欲了解更多信息看一看Constructing a Kinesis object

要写入/放记录使用以下

var params = { 
    Data: new Buffer('...') || 'STRING_VALUE', /* required */ 
    PartitionKey: 'STRING_VALUE', /* required */ 
    StreamName: 'STRING_VALUE', /* required */ 
    ExplicitHashKey: 'STRING_VALUE', 
    SequenceNumberForOrdering: 'STRING_VALUE' 
}; 
kinesis.putRecord(params, function (err, data) { 
    if (err) console.log(err, err.stack); // an error occurred 
    else  console.log(data);   // successful response 
});

欲了解更多信息离子看一看Calling the putRecord operation

来源

2017-06-22 08:45:04 MaiKaY

有上面的方法将在技术上工作，但硬编码的信誉，甚至配置信用成一个lambda似乎有点无关，因为lambda本身需要你有一个角色。你需要做的是创建一个交叉账户信任并使用sts承担角色。

在具有kinesis流的帐户中创建角色，并将其设置为信任您的lambda角色。

给这个角色一个允许它放入kinesis流的策略。

在您的lambda代码中，使用sts在具有kinesis流的帐户中创建会话并放入您的记录。

请注意，您的lambda需要一个策略，允许它插入第二个帐户的角色。

它在这里有更清楚的描述 Providing Access to Accounts you Own

来源

2017-06-22 19:41:40 jeffrey

使用lambda函数将数据发送到kinesis流（在不同的AWS账户中）

回答

相关问题