Hi Jan, stream-compatible data sources are starting to appear, see for example Slick 3.0 with its DBIO model that can either return a Future[] or a Publisher[] of the query result. The former would be incorporated using mapAsync and the latter can be wrapped in a Source and (with some care, usually) integrated into a stream using `.flatten(FlattenStrategy.concat)`. Rate limiting is described in the documentation (see the Cookbook), for retries you’ll have to construct a feedback cycle in the stream graph (e.g. like in the HTTP client <https://github.com/akka/akka/blob/release-2.3-dev/akka-http-core/src/main/scala/akka/http/impl/engine/client/PoolFlow.scala>; it is a bit involved but we might later condense this pattern into a readily reusable flow element).
When it comes to streaming data sinks there also is movement e.g. in the form of reactive Kafka drivers, we should see Cassandra and Spark as well soon, but this movement has just begun. I am not aware of an FTP implementation for Akka Streams yet, maybe someone has done that and would speak up? Regards, Roland On Wed, Aug 12, 2015 at 12:23 PM, algermissen1971 <[email protected]> wrote: > Hi all, > > I am looking for an akka-streams example that shows how one would approach > talking to databases (or an FTP server in my case). > > Besides the basic question of how to create a Source or Sink on top of a > database driver (or SFTP connection for that matter) I am looking for best > practices on rate limiting and retries, or re-establishing a connection if > it gets lost. > > Can somone point me to an example to get started? > > Jan > > > -- > >>>>>>>>>> Read the docs: http://akka.io/docs/ > >>>>>>>>>> Check the FAQ: > http://doc.akka.io/docs/akka/current/additional/faq.html > >>>>>>>>>> Search the archives: > https://groups.google.com/group/akka-user > --- > You received this message because you are subscribed to the Google Groups > "Akka User List" group. > To unsubscribe from this group and stop receiving emails from it, send an > email to [email protected]. > To post to this group, send email to [email protected]. > Visit this group at http://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > -- Akka Team Typesafe - Reactive apps on the JVM Blog: letitcrash.com Twitter: @akkateam -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
