問題タブ [alpakka]

IBM キュー (insert_queue) には 100 個のメッセージがあります。私は 10 を消費してオブジェクトに格納し、10 の消費されたメッセージを処理してしばらく待ってから、10 の消費されたメッセージを確認したいと考えています。

私のサンプルコード:

動作していない

slick profile の使い方がわかりません。

私の問題：

Alpakka JDBC プラグインを介して Akka-stream で Slick を使用しようとしています。オンラインで提供されている例は次のとおりです。

問題は、それが動作することです

暗黙の val セッション = SlickSession.forConfig("slick-h2")

私は次のように滑らかなセッションを使用しようとします:

私のpp設定は次のとおりです：

このコードは実行時に壊れます。

ただし、別のコードでは、Akka-Stream を使用していないため、slickSession を使用していません。

コードは完全に機能します。

これは、2 つの異なるものが必要なDatabase.forconfig("pp")とSlickSession.forConfig("slick-h2")に関係していると結論付けました。

Slick の Web サイトにプロファイルに関する説明がありますが、それは非常に理解しにくく、ほとんど指示がありません。使用可能なプロファイルとその構文は一覧表示されません。

したがって、私の質問は、2つのforConfigの違いは何ですか。プロファイルがどのように機能するか、どこで必要とされるか。データベースの 2 つの構成ファイルが同じ方法で処理されない理由。

最後に、オラクルのプロファイルは何ですか。slick 3.2.3 では、Slick は無料になりました。profile = "slick.jdbc.H2Profile$"のようにプロファイルが見つかりませんでした

構成ファイルの違い、期待されること、プロファイルの機能、および Oracle のプロファイルとは何かを明確にするのに役立つ人はいますか?

we are using alpakka latest S3 connector for downloading stream but it fails with max-length error as exceeded content length limit (8388608 bytes)! You can configure this by setting `akka.http.[server|client].parsing.max-content-length` or calling `HttpEntity.withSizeLimit` before materializing the dataBytes stream. ,stream as Source (downloading file from S3) and flow which calls to AMQP server using java amqp-client library , when we stream file less that 8M it process but larger file did not process and throw error highlighted above.

• Akka-http does not keep file in memory it streams directly from source , do we need to first keep file in memory and then stream it?

• Is Downstream i.e AMQP which is java client libary(5.3.0) is givig
  this issue , we are using One connection and one channel for Rabbit
  MQ?

  /li>