amazon-kinesis

0熱度

2回答

我有一個應用程序寫入DynamoDB表，我試圖讓Kinesis做我的聚合，然後將聚合數據寫入另一個DynamoDB表。流在我的DynamoDB表啓用，和我對流Lamdba觸發如下： 'use strict'; var AWS = require('aws-sdk'); var kinesis = new AWS.Kinesis(); exports.handler = (event,

0熱度

1回答

使用「Amazon ES進行內容推薦」意味着什麼？

查看amazon kinesis分析的市場營銷文獻，我正在瀏覽他們的實時日誌分析流程，他們有第四步將數據傳送到Amazon ES以獲取內容建議。什麼是亞馬遜ES？這是他們的彈性搜索服務嗎？如果是這樣，那麼從彈性搜索產生的個性化推薦如何？

2熱度

1回答

Aws雲形成模板：如何爲Kinesis資源提供保留期？

Aws雲形成模板：如何爲Kinesis資源提供保留期？嗨，我想指定Kinesis的保留期限，我沒有在文檔中找到任何屬性。有沒有辦法做到這一點？

0熱度

1回答

想要將來自各個賬戶的AWS雲軌跡彙總到主AWS賬戶

得到了與以下解決方案的工作，但想知道是否有更好的方法。工作溶液 CustomerA（Cloudtrails）---> CustomerA（CloudWatch的） - >主站（S3 桶） - >主站（LAMBDA） - >主站（室壁運動）試過以下，但不能得到這些工作（這些是可能的嗎？） CustomerA（Cloudtrails） - > CustomerA（CloudWatch的） - -

0熱度

2回答

Spark Streaming Kinesis集成：初始化Worker中的LeaseCoordinator時出錯

我在使用scala中的kinesis應用程序運行簡單的vanilla spark流時遇到了一些問題。我在一些教程中遵循了基本指導，如Snowplow和WordCountASL。但我仍然不能讓它因爲這室壁運動工作者錯誤的工作： 16/11/15 09:00:27 ERROR Worker: Caught exception when initializing LeaseCoordinator c

1熱度

1回答

Amazon Kinesis Streams - 每個分片有多個「主題」？

我對Kinesis Streams相當陌生，花了很多時間閱讀文檔，但無法確定是否可能在單個分片上有多個「主題」（缺少更好的術語）。最初我以爲這是分區鍵的用途，但是reading this：分區鍵用於按流中的分片分組數據。 Streams服務使用與每個數據記錄關聯的分區鍵來確定屬於某個流的數據記錄爲多個分片，以確定給定數據記錄屬於哪個分片。 ...它聽起來像分區（可）跨越多個分片。我目前不需要超

0熱度

1回答

同步本地Sqlite數據與kinesis流

我正在開發一個android應用程序，它將存儲數據在sqlite數據庫它將更新Kinesis流，但是，當沒有網絡我無法管理舊數據進入kinesis。我想知道有什麼方法可以將sqlite數據庫與kinesis流同步，同步我的數據一旦我有互聯網連接？

0熱度

1回答

計算一系列kinesis流跟隨lambda的端到端時間

我們有一個系統接受輸入記錄並應用一系列使用kinesis流和lambda運行的轉換。 KinesisStream - > InputRecord - > Lambda1/Lambda2並行運行 - >輸出1室壁運動流 - > Lambda3 - >輸出2室壁運動流 - >存儲到DynamoDB LAMBDA CloudWatch的文檔@http://docs.aws.amazon.com/lamb

0熱度

1回答

Kinesis閱讀失敗的某些記錄

度量標準GetRecord.success在某段時間內顯示零值。這是否意味着某些記錄不是從Kinesis讀取的？ ReadProvisionedThroughputExceeded值雖然爲零。

7熱度

2回答

如何扇出AWS kinesis流？

我想扇出/鏈/複製一個輸入AWS Kinesis流到N個新Kinesis流，這樣寫入輸入Kinesis的每條記錄都會出現在N個流的每一箇中。是否有AWS服務或開源解決方案？如果有現成的解決方案，我寧願不寫代碼來做這件事。 AWS Kinesis firehose是無法解決的，因爲它不能輸出到kinesis。如果AWS Lambda解決方案的運行成本不高，那麼可能是AWS Lambda解決方案？