amazon-kinesis

0熱度

1回答

我已經將API網關配置爲Kinesis代理，如Amazon的教程中所述將記錄放入Kinesis流中。集成請求的HTTP標頭是：內容類型被映射到應用程序/ x-AMZ-JSON-1.1 針對內容類型的應用程序本體映射模板/ JSON看起來像： #set($event = "{ ""rows"": ""$input.json('$')"", ""uuid"": ""$input.par

2熱度

1回答

在由Kinesis觸發的AWS Lambda中，是否有使用回調成功消息的理由？

我是AWS的新手，特別是Lambda錯綜複雜。我目前的目標是獲得一個監聽Kinesis流的Lambda函數。我很好奇的是，在Kinesis流觸發Lambda函數的情況下，誰是調用者（用於Lambda的export.handler回調）？換句話說，在Lambda成功執行回調時，誰是接收成功消息的主叫方？而且這會被使用嗎？例如，對於一個空白lambda函數起始模板： exports.handler

1熱度

1回答

AmazonKinesisClient構造函數已被棄用

我想使用Java創建Kinesis流。所以我遵循aws doc（URL：http://docs.aws.amazon.com/streams/latest/dev/kinesis-using-sdk-java-create-stream.html）。據此，首先我必須創建Kinesis Streams客戶端。我嘗試它給出的代碼是： client = new AmazonKinesisClient()

0熱度

1回答

Amazon Kinesis - 獲取每個碎片中的記錄數

有沒有方法可以查找Amazon Kinesis中給定流的每個碎片中的記錄數？有啓用增強監控可用，但我無法找到一種方法來顯示cloudwatch中的碎片ID，如果這是一個選項。

2熱度

1回答

使用Java SDK將記錄放入Kinesis流時，sequenceNumberForOrdering做了什麼？

我有點困惑的AWS文檔爲把記錄的Kinesis流在這裏：https://docs.aws.amazon.com/kinesis/latest/APIReference/API_PutRecord.html#API_PutRecord_RequestSyntax 它說，設置sequenceNumberForOrdering應該用於保障秩序「來自同一客戶和同一分區鍵看跌期權」。在this page最

1熱度

1回答

如何室壁運動示例腳本解析「未定義的變量」？

我在跟隨的Python 3.6.2文檔。 100％新Python和從網上抓取的例子來學習我有一個腳本在這裏，我試圖讓工作： Getting Started with AWS Kinesis and Python 我的PyDev IDE說：「未定義的變量：響應」的腳本的第10行： 1）作爲新的Python的，我canno理解這裏使用的語言結構是什麼？它看起來像一個多維陣列（從Java背景是未來.

1熱度

1回答

使用隊列可靠地將事件從API網關推送到Lambda

我目前有第三方應用程序通過API網關將消息推送到Lambda函數。 Lambda函數需要序列化，記錄並將消息推送到另一個我幾乎無法控制的ESB。我試圖確保在Lambda函數處於最大負載或無法與ESB通信的情況下存在某種恢復機制。我已經讀過關於Kinesis是一個很好的選擇，但ESB不支持我的用例的批處理。這會導致我遇到一些消息可能會使其進入ESB的情況，而其他消息則不會最終導致批處理失敗。然後

0熱度

2回答

是否可以爲Kinesis Analytics設置多個輸入流？

我有3個作爲輸入源的mongodb集合（來自相同數據庫）。目前我正在使用3個kinesis流來訪問這些集合。我需要結合他們來分析他們。我可以使用Kinesis Analytics來做到這一點嗎？因爲我看不到選擇多個流作爲Kinesis Analytic應用程序的輸入的選項。

1熱度

1回答

出版退出

我試圖發佈從AWS拉姆達事件，但我得到以下錯誤： Process exited before completing request 這裏是我的代碼 exports.handler = (event, context, callback) => { kinesis.PutRecord({ "Data": event, "PartitionKey" : "1",

0熱度

1回答

aws kinesis流以較低的速率向lambda發送數據

我需要使用aws kinesis流& lambda來實現某種流解決方案。我添加了第一個用於添加數據流的lambda。第一個Lambda本身每10秒調用一次，並添加100個數據請求（每個1kb）流。我運行了兩個調用lambda的腳本實例。第二個lambda使用上面的流作爲觸發器。在小容量數據/間隔第二個lambda上同時獲取數據。但是，在上述的數據中，數據的準確性會降低（在+1小時流播後，速度會降