私の Google Cloud Dataflow の使用例は、発生する変換がキャッシュされたデータに依存するため、パイプライン中に Redis をキャッシュとして使用することです。これは、Redis GET コマンドを実行することを意味します。公式の組み込み Redis I/O 変換のドキュメントには、いくつかの方法をサポートすることが記載されています。
read - 「キーと値のペアを KV として含む制限付き PCollection を返すソースを提供します」
readAll - 「入力 PCollection 要素をキー パターン (文字列) として使用して、Redis サーバーを要求するために使用できます」
readAll は GET コマンドに対応していないように見えますが、入力 PCollection は Redis ソース全体をスキャンした結果をフィルター処理するために使用されるため、これは私が探しているものではありません。
私のユースケースを可能にする組み込みの I/O 変換を調べたときに何か欠けているものがあるかどうか、またはそれをサポートするオープンソースのサードパーティ I/O 変換のような代替手段があるかどうか疑問に思っていました。それとも、Apache Beam とは根本的に互換性がないものなのでしょうか?