amazon-kinesis

4熱度

2回答

如何分辨讀取器已經處理的Kinesis流中的數據百分比？我知道每個讀者都有一個每個分片檢查點序列號，我也可以從describe-stream獲得每個分片的StartingSequenceNumber，但是，我不知道讀者目前的數據有多遠（我不知道知道碎片的最新序列號）。我正在考慮爲每個分片獲取最新的迭代器並獲取最後一條記錄的序列號，但是如果自得到最新的迭代器以來沒有新數據，這似乎不起作用。任何想

2熱度

1回答

有沒有辦法以編程方式獲取Amazon Kinesis流的最大授權分片數量？

默認情況下，Kinesis流被授權擁有至多10個分片，但可以增加此限制。是否有可能以編程方式檢索流限制？我無法在官方的AWS Java SDK中找到一種方法。

2熱度

2回答

使用Jmeter的HTTP請求將記錄放入Amazon Kinesis

我使用jmeter爲我的webservice REST創建HTTP請求。現在我想使用PutRecords方法將此請求發送到Amazon kinesis，但我不知道如何創建請求，特別是如何設置標題字段來簽名和驗證kinesis。有人使用過休息請求嗎？感謝

0熱度

1回答

AWS Kinesis寫入吞吐量沒有數據，但有總數傳入請求中的數據

您好我正在使用Kinesis來處理數據流。我可以成功發送數據到Kinesis並從Kinesis中提取數據，一切都很好。但是，當我檢查Kinesis的「監視」時，我沒有看到寫入吞吐量的數據，但有總數傳入請求的數據（在附加的屏幕截圖中）。由於我可以成功地從Kinesis中提取數據，我假設必須有一些寫入吞吐量，在監視中怎麼沒有寫入吞吐量？或者我誤解了「寫入吞吐量」和「傳入請求」這個詞？非常感謝。

5熱度

2回答

如何驗證Amazon Kinesis Python客戶端正在工作

我正在嘗試使用Python的KCL庫（https://github.com/awslabs/amazon-kinesis-client-python）構建Amazon Kinesis Python使用者。我從檢查示例代碼開始。我能夠運行示例代碼的生產者和用戶腳本部分，但我無法驗證是否將來自我的kinesis流（帶有一個分片）的數據推送到示例Python使用者腳本sample_kclpy_app.p

1熱度

2回答

Jmeter和全局Beanshell變量

jmeter可能在不同的BeanShell採樣器中使用相同的變量嗎？我的目標是將我的Amazon Kinesis Java應用程序（轉換）導入到Jmeter中，但部分代碼是連接，我想在啓動jmeter應用程序時設置一次。所以我必須在不同的beanshell中重用AmazonKinesisClient變量。可能嗎？感謝 PS：我有JSONObject的同樣的問題，但在這種情況下，我已經使用了JM

1熱度

1回答

在使用Kinesis MultiLangDaemon/KCL時調試nodejs

關注this post我能夠將現有的nodejs代碼連接到Kinesis日誌（使用KCL和MultiLangDaemon）。問題是我無法再調試代碼。由於MultiLangDaemon使用標準輸入/輸出與執行的「腳本」互動，有一次我稱之爲「節點--debug」，看到消息：「調試器監聽端口57846」我得到從MultiLangDaemon說一個錯誤：「重度：從子收到的錯誤線[調試器監聽端口5

0熱度

1回答

問題使用Scalazon創建Kinesis流

我正在關注Scalazon示例here以創建Kinesis流。下面的代碼： val streamListFuture = for { s <- Kinesis.streams.list } yield s 提供了以下錯誤： [error] KinesisStatsWriter.scala:51: value map is not a member of object io.gith

0熱度

1回答

Amazon Kinesis發行商

我想爲亞馬遜Kinesis創建POC。我已經創建了AWS流和一些代碼這篇文章http://seroter.wordpress.com/2014/01/09/data-stream-processing-with-amazon-kinesis-and-net-applications/ 我得到異常Amazon.Kinesis.Model.ResourceNotFoundException的幫

0熱度

1回答

通過Java代碼將多個項目放入DynamoDB中

我想使用SDK Amazon的batchWriteItem方法將大量項目放入表格中。我回顧了Kinesis的項目，它有很多碎片。我用這個方法對一個項目： public static void addSingleRecord(Item thingRecord) { // Add an item try { DynamoDB dynamo = new