amazon-kinesis

0熱度

1回答

我的應用程序讀取dynamoDB流以查找更改一個表，我目前得到的最新數據流是這樣的： this.awsDB.describeTable({TableName: 'MatchDraft'}, function(err, data){ if(err){ console.log(err); } else { this.streamArn = data.Table.

3熱度

2回答

爲什麼我會在amazon-kinesis-client中獲取JSONObject上的NoClassDefFoundError？

我已經納入從DynamoDB的碼流從AWS-dynamodb-例子適配器演示，到我的Maven項目，並且我得到一個運行時錯誤： Exception in thread "Thread-2" java.lang.NoClassDefFoundError: com/amazonaws/util/json/JSONObject at com.amazonaws.services.kinesis.lea

0熱度

1回答

如何在KCL中重新排序異步發送Kinesis Events

我正在研究使用Kinesis客戶端庫（KCL）從AWS Kinesis Stream中讀取和處理事件的應用程序。我不希望事件生產者端遭受延遲，因此使用KinesisAsyncClient發送事件。但是爲了讓我的事件處理正常工作，我需要在生產者端處理「我稱爲putRecordAsync的命令」中的均衡器。這些信息作爲每個Kinesis記錄中的時間戳字段提供。除了切換使用阻塞同步Kinesis客戶端

0熱度

1回答

Kinesis - 消費者集羣

我有一個kinesis流，用於排隊任務，比如發送電子郵件。我有一羣消費者應該閱讀隊列，然後發送電子郵件。在這種情況下，如果消費者從隊列中讀取一個項目，其他消費者不應讀取相同的項目;其他我會發送重複的電子郵件。我該如何做到這一點？

0熱度

2回答

Kinesis ProvisionedThroughputExceededException即使在足夠的分片之後

在Kinesis流上寫入數據時，我們面臨ProvisionedThroughputExceededException問題。案例1：我們使用單m4.4xlarge（16核心，64GB MEM）實例寫在流遍數據從3K的JMeter要求，EC2實例爲我們提供了每秒1100的要求，所以我們選擇2碎片流（即2000 eps）。因此，我們能夠成功寫入數據流而沒有任何損失。情況2：對於進一步的測試我們

0熱度

1回答

如何使用AWS製作打字指示符？

我是AWS新手，我發現了一些模塊，如AWS Lambda，dynamodb，SNS，cloudsearch等。我想知道如何設置聊天輸入指示器。這意味着在聊天界面中會在底部顯示一個小文本（或動畫圖標），以實時通知您您的聊天夥伴正在輸入消息。這聽起來相對簡單，但我不得不承認，我有一些困難，想用aws樂器設置這個功能。任何解釋和良好的意見將不勝感激。謝謝

0熱度

1回答

如何將使用Amazon API網關的json數據放入Kinesis流

我使用amazon api網關設置了一個API，並且希望將數據放入kinesis流中。亞馬遜的api網關已經內置了對它的支持。但是當我試圖把json數據給出「序列化異常」。 var data = {"ua_platform":"iPhone","ua_browsercodename":"Mozilla","ua_browserlanguage":"en-us","ua_header":"Mozil

7熱度

1回答

汽車線kinesis流kinesis firehose？

我將數據發佈到由某些消費者處理的kinesis流。我希望發佈到流中的原始數據也存儲在s3中。是否有可能將kinesis流自動連接到kinesis流水線，還是需要直接發佈到kinesis消費者的流水線？

2熱度

3回答

串連S3文件使用AWS流水

時，我有一個AWS Kinesis流水流將數據放入S3具有以下配置： S3 buffer size (MB)* 2 S3 buffer interval (sec)* 60 ，一切工作正常。唯一的問題是Firehose爲每個數據塊創建一個s3文件。（在我的情況下，每分鐘一個文件，如截圖中所示）。隨着時間的推移，這是很多文件：每天1440個文件，每年525k個文件。這是很難管理（例如，如

1熱度

1回答

Boto3從Kinesis流中讀取時間戳

我正在嘗試從Kinesis流讀取。如果我使用ShardIteratorTypeAT_SEQUENCE_NUMBER或LATEST，它工作正常。但是，如果我嘗試使用AT_TIMESTAMP類型，並設置一個TIMESTAMP，boto3抱怨： File "/usr/local/lib/python2.7/site-packages/botocore/validate.py", line 269, in