ストリーミングをサポートしていないデータベースに対して、どのように再アクティブストリームAPIを提供しますか? likeは例えばdynamodbと言うことができます。 getコールをするとき、dynamodbはすべての結果を返します。だから私がソースでgetコールをラップしても、どのように私は下流の段階から背圧を処理するのですか?また、どのように私はdbに書き込み呼び出しを実装するのですか?私のシンクはどのように見えますか?これに関するあらゆる指針が役立ちます。データベースにリアクティブAPIを提供する
1
A
答えて
0
1つのオプションは、使用してデータベースSource
を実装することですActorPublisher
-
参照:http://doc.akka.io/docs/akka/2.4.11/scala/stream/stream-integrations.html#ActorPublisher
ただ、この特性で混合し、あなたにダウン扱うことができる反応性ストリーム対応のデータ・パブリッシャを与えるコマンドインタフェースを実装しますストリーム背圧。購読者がダウンストリームでより多くのデータをプルすると、パブリッシャーはRequest
というメッセージを受け取り、より多くのデータをダウンストリームに積極的にプッシュする必要がある場合、現在の認識された需要にアクセスできるようになります。あなたはそれからSource
を作成することによって、あなたのアッカストリームパイプラインにこの出版社を差し込むことができます。
Source.actorPublisher[Data](MyPublisher.props).runWith(MySink)
基礎となるDBは、反応性そのものではないという事実に対処するためには、内のいくつかのバッファリングとポーリングロジックを実装する必要がありますActorPublisher
。
関連する問題
- 1. Sendgrid API提供
- 2. jQueryプラグイン - APIを提供
- 3. PHPはSpinxクライアントAPIを提供するようにLucene Client APIを提供していますか?
- 4. フェデレーションユーザーのグラフAPIの提供
- 5. ポータブルエリアへのAPIの提供
- 6. wso2 APIマネージャーにダミーapisを提供
- 7. メタデータを提供するようにWeb APIを設定する
- 8. 反応するネイティブスナップカルーセルにAPIデータを提供する方法
- 9. Ionic AppからREST APIを提供
- 10. PayPal REST Sandbox API INTERNAL_SERVICE_ERRORを提供
- 11. JavaでRESTful JSON APIを提供
- 12. 大きなデータベースをAppに提供する方法
- 13. MongoDBユーザーに追加のデータベースへのアクセスを提供する
- 14. 会社が提供するAPIに接続する
- 15. APIにSSLを提供する方法は?
- 16. 私たちのシステムにAPIを提供する方法
- 17. ウェブAPIへのパブリックアクセスを提供するには?
- 18. サーバーのAPIを提供している間に静的ファイルを提供できますか?
- 19. APIサーバーからのサービス提供
- 20. APIクライアントに1,000,000件のデータベース結果を提供するにはどうすればよいですか?
- 21. 統合APIの提供に関する推奨事項
- 22. アプリケーションサーバーは、提供できるSpringを提供しますか?
- 23. Google Cloud Vision APIにFirebase Storageへのアクセスを提供します。
- 24. GoogleマップAPIキーをPHPとカールで提供する方法
- 25. 利用可能な屋内マップのリストを提供するAPI
- 26. HerokuでREST APIを提供する方法
- 27. APIを提供する電話会議サービス?
- 28. GraphQL APIから取得するクエリ文字列を提供
- 29. 残りのAPIを提供するRapidMinerクラウド
- 30. 経費提供者としてuber apiを使用する