Amazon Kinesis Publisher
Amazon Kinesis Publisher
提问于 2014-12-29 18:58:55
我想为Amazon Kinesis创建一个POC。
在本文http://seroter.wordpress.com/2014/01/09/data-stream-processing-with-amazon-kinesis-and-net-applications/的帮助下，我已经在亚马逊网络服务上创建了一个流和一些代码
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;
}未找到帐户111111111111下的异常Amazon.Kinesis.Model.ResourceNotFoundException:流POC。
回答 1
Stack Overflow用户
发布于 2015-01-02 15:53:25
您的管理员创建流的地域验证了吗？检查流是否存在并将其创建为POC应用程序的一部分(如果您使用的密钥具有权限)会更容易
var response = CreateStream(new Amazon.Kinesis.Model.CreateStreamRequest()
{
ShardCount = shardCount,
StreamName = name
});页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/27687552
复制相关文章
相似问题
腾讯云开发者
