我想为 Amazon Kinesis 创建一个 POC。
我在本文的帮助下在 AWS 上创建了一个流和一些代码http://seroter.wordpress.com/2014/01/09/data-stream-processing-with-amazon-kinesis-and-net-应用/
using (MemoryStream ms = new MemoryStream(oByte))
{
AmazonKinesisConfig config = new AmazonKinesisConfig();
config.RegionEndpoint = Amazon.RegionEndpoint.USEast1;
AmazonKinesisClient client = new AmazonKinesisClient(config);
PutRecordRequest requestRecord = new PutRecordRequest();
requestRecord.StreamName = "POC";
requestRecord.PartitionKey = "weborder";
requestRecord.Data = ms;
try
{
var responseRecord = client.PutRecord(requestRecord);
}
catch (Exception ex)
{
var t = ex.Message;
}
lblShardId.Text = "Shard ID: " + responseRecord.ShardId;
lblSequence.Text = "Sequence #:" + responseRecord.SequenceNumber;
}
我得到一个例外
Amazon.Kinesis.Model.ResourceNotFoundException: Stream POC under account 111111111111 not found.
您是否已验证您的管理员创建流的区域? 更容易检查流是否存在并将其创建为 POC 应用程序的一部分(如果您使用的密钥具有权限)
var response = CreateStream(new Amazon.Kinesis.Model.CreateStreamRequest()
{
ShardCount = shardCount,
StreamName = name
});