私は入力ソースとして機能する3つのmongodbコレクション(同じデータベースから)を持っています。現在私は3つのキネシスストリームを使ってこれらのコレクションにアクセスしています。私はそれらを組み合わせて分析する必要があります。これを行うにはKinesis Analyticsを使用できますか?なぜなら私はKinesis Analyticアプリケーションの入力として複数のストリームを選択するオプションを見ることができないからです。Kinesis Analytics用に複数の入力ストリームを設定することはできますか?
0
A
答えて
0
Kinesis Analyticsには、まだ複数のストリーミングソースと1つの参照データソースを追加する機能がありません。
参照:http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html
0
あなたはDrools Kinesis Analyticsを使用することができ、複数の入力をサポートしています(AWSのスポーツチームもそれを確認)はい、それはある
関連する問題
- 1. Amazon Kinesis Analyticsでジオコードデータを元に戻すことはできますか?
- 2. ファイルビートに複数の出力を設定することはできますか?
- 3. Ionic 2ウェブアプリケーション用にGoogle Analyticsを設定することはできますか?
- 4. KinesisストリームにAmazon APIゲートウェイを使用してjsonデータを入力する方法
- 5. 入力パラメータに複数の入力ストリームを使用するにはどうすればよいですか?
- 6. Androidでオーディオ入力(マイク)ストリームを共有することはできますか?
- 7. MVCFormに複数のモデルを設定することはできますか?
- 8. キネシス入力ストリームをLogstashに入力
- 9. カフカ入力ストリームを複数の出力ストリームに動的に接続する
- 10. モバイルアプリ(iOS + Android)用に設定可能なアプリアイコンを複数設定することはできますか?
- 11. 設定logstash:複数入力
- 12. "x:Class"をResourceDictionaryファイルに複数設定することはできますか?
- 13. 複数のヘッダをSiegeで設定することはできますか?
- 14. php://入力ストリームをバッファから読み込むことはできますか?
- 15. PortAudioコールバックを使用してストリームの入力バッファに書き戻すことはできますか?
- 16. 複数の入出力にtf.map_fn(...)を適用できますか?
- 17. ストリーム入力にXIncludeを使用できますか?
- 18. 複数のデバイスからの入力用にapache chainsawを設定する方法
- 19. 標準入力/出力をC言語のファイルに設定することはできますか?
- 20. recurly jsフォームを複数回ビルド(設定)することはできますか?
- 21. 複数の行を入力としてテキスト選択を行うことができるVBAで '入力ボックス'を作成することはできますか?
- 22. 同じKinesisストリームの複数の異なるコンシューマー
- 23. Kinesis Analytics SQL:ThrotteはN分ごとに1行だけです
- 24. どのように私たちは、正の整数を入力することができますアンドロイドのテキストフィールドを設定することができます
- 25. Google Analytics - スクリプトをフッターに入れることはできますか?
- 26. 入力ストリームからオーディオ入力ストリームを取得できませんでした
- 27. Matlabでは、複数入力関数の場合、1つの入力を複数の入力として使用する方法はありますか?
- 28. 関数内のユーザー入力は、「グローバル」にすることはできますか?
- 29. キーボードをテンキーパッドとして設定するにはどうすればいいですか?Xamarin.Formsに負の数を入力することはできますか?
- 30. 複数のホストで同じドメイン名を使用してウェブサイトを設定することはできますか?
をストリーミングします。私の状況を克服するために、キネシスの流れを組み合わせる方法を知っていますか? – GihanDB
Kinesis Analyticsの制限に関するドキュメント - 「各アプリケーションには、1つのストリーミングソースと1つの参照データソースがあります。私はあなたが複数の宛先を指していると信じています - それはCLI/SDK(コンソールからは不可能)を使って行うことができます。ユースケースになると、私はこれを行う直接的な方法はわかりませんが、潜在的な回避策がある可能性があります。 – Pushpesh
[1]プッシュデータを1つのストリームに送信し、Kinesis Analytics InApp Streamsを使用してレコード/収集データをフィルタリングすることができます。 [2]ストリームにレコードをプッシュしている間に別のストリームを追加する(AllCollectionsStreamと言う)各レコードを個々のストリームにプッシュするロジックをプロデューサに追加する+ AllCollectionsStream – Pushpesh