2017-07-27 9 views
0

私は入力ソースとして機能する3つのmongodbコレクション(同じデータベースから)を持っています。現在私は3つのキネシスストリームを使ってこれらのコレクションにアクセスしています。私はそれらを組み合わせて分析する必要があります。これを行うにはKinesis Analyticsを使用できますか?なぜなら私はKinesis Analyticアプリケーションの入力として複数のストリームを選択するオプションを見ることができないからです。Kinesis Analytics用に複数の入力ストリームを設定することはできますか?

答えて

0

Kinesis Analyticsには、まだ複数のストリーミングソースと1つの参照データソースを追加する機能がありません。

参照:http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html

+0

をストリーミングします。私の状況を克服するために、キネシスの流れを組み合わせる方法を知っていますか? – GihanDB

+0

Kinesis Analyticsの制限に関するドキュメント - 「各アプリケーションには、1つのストリーミングソースと1つの参照データソースがあります。私はあなたが複数の宛先を指していると信じています - それはCLI/SDK(コンソールからは不可能)を使っ​​て行うことができます。ユースケースになると、私はこれを行う直接的な方法はわかりませんが、潜在的な回避策がある可能性があります。 – Pushpesh

+0

[1]プッシュデータを1つのストリームに送信し、Kinesis Analytics InApp Streamsを使用してレコード/収集データをフィルタリングすることができます。 [2]ストリームにレコードをプッシュしている間に別のストリームを追加する(AllCollectionsStreamと言う)各レコードを個々のストリームにプッシュするロジックをプロデューサに追加する+ AllCollectionsStream – Pushpesh

0

あなたはDrools Kinesis Analyticsを使用することができ、複数の入力をサポートしています(AWSのスポーツチームもそれを確認)はい、それはある

関連する問題