AWS Lambda
The AWS Lambda connector provides Akka Flow for AWS Lambda integration.
For more information about AWS Lambda please visit the AWS lambda documentation.
Project Info: Alpakka AWS Lambda | |
---|---|
Artifact | com.lightbend.akka
akka-stream-alpakka-awslambda
2.0.2
|
JDK versions | Adopt OpenJDK 8 Adopt OpenJDK 11 |
Scala versions | 2.12.11, 2.11.12, 2.13.3 |
JPMS module name | akka.stream.alpakka.aws.lambda |
License | |
Readiness level |
Since 0.6, 2017-02-13
|
Home page | https://doc.akka.io/docs/alpakka/current |
API documentation | |
Forums | |
Release notes | In the documentation |
Issues | Github issues |
Sources | https://github.com/akka/alpakka |
Artifacts
- sbt
val AkkaVersion = "2.5.31" libraryDependencies ++= Seq( "com.lightbend.akka" %% "akka-stream-alpakka-awslambda" % "2.0.2", "com.typesafe.akka" %% "akka-stream" % AkkaVersion )
- Maven
<properties> <akka.version>2.5.31</akka.version> <scala.binary.version>2.12</scala.binary.version> </properties> <dependency> <groupId>com.lightbend.akka</groupId> <artifactId>akka-stream-alpakka-awslambda_${scala.binary.version}</artifactId> <version>2.0.2</version> </dependency> <dependency> <groupId>com.typesafe.akka</groupId> <artifactId>akka-stream_${scala.binary.version}</artifactId> <version>${akka.version}</version> </dependency>
- Gradle
versions += [ AkkaVersion: "2.5.31", ScalaBinary: "2.12" ] dependencies { compile group: 'com.lightbend.akka', name: "akka-stream-alpakka-awslambda_${versions.ScalaBinary}", version: '2.0.2', compile group: 'com.typesafe.akka', name: "akka-stream_${versions.ScalaBinary}", version: versions.AkkaVersion }
The table below shows direct dependencies of this module and the second tab shows all libraries it depends on transitively.
- Direct dependencies
Organization Artifact Version com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.github.matsluni aws-spi-akka-http_2.12 0.0.9 com.typesafe.akka akka-http_2.12 10.1.11 com.typesafe.akka akka-stream_2.12 2.5.31 org.scala-lang scala-library 2.12.11 software.amazon.awssdk lambda 2.11.14 - Dependency tree
com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 com.github.matsluni aws-spi-akka-http_2.12 0.0.9 org.scala-lang scala-library 2.12.11 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 com.typesafe.akka akka-http_2.12 10.1.11 com.typesafe.akka akka-http-core_2.12 10.1.11 com.typesafe.akka akka-parsing_2.12 10.1.11 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 com.typesafe.akka akka-stream_2.12 2.5.31 com.typesafe.akka akka-actor_2.12 2.5.31 com.typesafe config 1.3.3 org.scala-lang.modules scala-java8-compat_2.12 0.8.0 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 com.typesafe.akka akka-protobuf_2.12 2.5.31 org.scala-lang scala-library 2.12.11 com.typesafe ssl-config-core_2.12 0.3.8 com.typesafe config 1.3.3 org.scala-lang.modules scala-parser-combinators_2.12 1.1.2 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 org.reactivestreams reactive-streams 1.0.2 org.scala-lang scala-library 2.12.11 org.scala-lang scala-library 2.12.11 software.amazon.awssdk lambda 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk aws-core 2.11.14 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk aws-json-protocol 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk aws-core 2.11.14 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk auth 2.11.14 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.eventstream eventstream 1.0.1 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk protocol-core 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk protocol-core 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk regions 2.11.14 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk sdk-core 2.11.14 com.fasterxml.jackson.core jackson-core 2.10.5 com.fasterxml.jackson.core jackson-databind 2.10.5 com.fasterxml.jackson.core jackson-annotations 2.10.5 com.fasterxml.jackson.core jackson-core 2.10.5 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk http-client-spi 2.11.14 org.reactivestreams reactive-streams 1.0.2 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk profiles 2.11.14 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14 software.amazon.awssdk utils 2.11.14 org.reactivestreams reactive-streams 1.0.2 org.slf4j slf4j-api 1.7.28 software.amazon.awssdk annotations 2.11.14
Setup
The flow provided by this connector needs a prepared LambdaAsyncClient
to be able to invoke lambda functions.
- Scala
-
import com.github.matsluni.akkahttpspi.AkkaHttpClient import software.amazon.awssdk.auth.credentials.{AwsBasicCredentials, StaticCredentialsProvider} import software.amazon.awssdk.services.lambda.LambdaAsyncClient // Don't encode credentials in your source code! // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html val credentialsProvider = StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x")) implicit val lambdaClient: LambdaAsyncClient = LambdaAsyncClient .builder() .credentialsProvider(credentialsProvider) .httpClient(AkkaHttpClient.builder().withActorSystem(system).build()) // Possibility to configure the retry policy // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html // .overrideConfiguration(...) .build() system.registerOnTermination(lambdaClient.close())
- Java
-
import com.github.matsluni.akkahttpspi.AkkaHttpClient; import software.amazon.awssdk.auth.credentials.AwsBasicCredentials; import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider; import software.amazon.awssdk.services.lambda.LambdaAsyncClient; // Don't encode credentials in your source code! // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html StaticCredentialsProvider credentialsProvider = StaticCredentialsProvider.create(AwsBasicCredentials.create("x", "x")); LambdaAsyncClient awsLambdaClient = LambdaAsyncClient.builder() .credentialsProvider(credentialsProvider) .httpClient(AkkaHttpClient.builder().withActorSystem(system).build()) // Possibility to configure the retry policy // see https://doc.akka.io/docs/alpakka/current/aws-shared-configuration.html // .overrideConfiguration(...) .build(); system.registerOnTermination(awsLambdaClient::close);
The example above uses Akka HTTP as the default HTTP client implementation. For more details about the HTTP client, configuring request retrying and best practices for credentials, see AWS client configuration for more details.
We will also need an ActorSystem
ActorSystem
and an Materializer
Materializer
.
- Scala
-
import akka.actor.ActorSystem import akka.stream.{ActorMaterializer, Materializer} implicit val system: ActorSystem = ActorSystem() implicit val mat: Materializer = ActorMaterializer()
- Java
-
import akka.actor.ActorSystem; import akka.stream.ActorMaterializer; import akka.stream.Materializer; ActorSystem system = ActorSystem.create(); Materializer materializer = ActorMaterializer.create(system);
This is all preparation that we are going to need.
Sending messages
Now we can stream AWS Java SDK Lambda InvokeRequest
to AWS Lambda functions AwsLambdaFlow
AwsLambdaFlow
factory.
- Scala
-
import software.amazon.awssdk.core.SdkBytes import software.amazon.awssdk.services.lambda.model.InvokeRequest val request = InvokeRequest .builder() .functionName("lambda-function-name") .payload(SdkBytes.fromUtf8String("test-payload")) .build() Source.single(request).via(AwsLambdaFlow(1)).runWith(Sink.seq)
- Java
-
import software.amazon.awssdk.services.lambda.model.InvokeRequest; import software.amazon.awssdk.services.lambda.model.InvokeResponse; import software.amazon.awssdk.core.SdkBytes; InvokeRequest request = InvokeRequest.builder() .functionName("lambda-function-name") .payload(SdkBytes.fromUtf8String("test-payload")) .build(); Flow<InvokeRequest, InvokeResponse, NotUsed> flow = AwsLambdaFlow.create(awsLambdaClient, 1); final CompletionStage<List<InvokeResponse>> stage = Source.single(request).via(flow).runWith(Sink.seq(), materializer);
AwsLambdaFlow configuration
Options:
parallelism
- Number of parallel executions. Should be less or equal to number of threads in ExecutorService for LambdaAsyncClient