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.0-RC1
JDK versions
Adopt OpenJDK 8
Adopt OpenJDK 11
Scala versions2.12.10, 2.11.12, 2.13.1
JPMS module nameakka.stream.alpakka.aws.lambda
License
Readiness level
Since 0.6, 2017-02-13
Home pagehttps://doc.akka.io/docs/alpakka/current
API documentation
Forums
Release notesIn the documentation
IssuesGithub issues
Sourceshttps://github.com/akka/alpakka

Artifacts

sbt
val AkkaVersion = "2.5.30"
libraryDependencies ++= Seq(
  "com.lightbend.akka" %% "akka-stream-alpakka-awslambda" % "2.0.0-RC1",
  "com.typesafe.akka" %% "akka-stream" % AkkaVersion
)
Maven
<properties>
  <akka.version>2.5.30</akka.version>
</properties>
<dependency>
  <groupId>com.lightbend.akka</groupId>
  <artifactId>akka-stream-alpakka-awslambda_2.12</artifactId>
  <version>2.0.0-RC1</version>
</dependency>
<dependency>
  <groupId>com.typesafe.akka</groupId>
  <artifactId>akka-stream_2.12</artifactId>
  <version>${akka.version}</version>
</dependency>
Gradle
versions += [
  AkkaVersion: "2.5.30"
]
dependencies {
  compile group: 'com.lightbend.akka', name: 'akka-stream-alpakka-awslambda_2.12', version: '2.0.0-RC1',
  compile group: 'com.typesafe.akka', name: 'akka-stream_2.12', 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
OrganizationArtifactVersion
com.fasterxml.jackson.corejackson-core2.10.0
com.fasterxml.jackson.corejackson-databind2.10.0
com.github.matsluniaws-spi-akka-http_2.120.0.7
com.typesafe.akkaakka-http_2.1210.1.11
com.typesafe.akkaakka-stream_2.122.5.30
org.scala-langscala-library2.12.10
software.amazon.awssdklambda2.10.60
Dependency tree
com.fasterxml.jackson.core    jackson-core    2.10.0
com.fasterxml.jackson.core    jackson-databind    2.10.0
    com.fasterxml.jackson.core    jackson-annotations    2.10.0
com.github.matsluni    aws-spi-akka-http_2.12    0.0.7
    software.amazon.awssdk    http-client-spi    2.10.60
        org.reactivestreams    reactive-streams    1.0.2
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
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
com.typesafe.akka    akka-stream_2.12    2.5.30
    com.typesafe.akka    akka-actor_2.12    2.5.30
        com.typesafe    config    1.3.3
        org.scala-lang.modules    scala-java8-compat_2.12    0.8.0
    com.typesafe.akka    akka-protobuf_2.12    2.5.30
    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.reactivestreams    reactive-streams    1.0.2
org.scala-lang    scala-library    2.12.10
software.amazon.awssdk    lambda    2.10.60
    software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    auth    2.10.60
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    http-client-spi    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    profiles    2.10.60
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    regions    2.10.60
            com.fasterxml.jackson.core    jackson-annotations    2.10.0
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    sdk-core    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    sdk-core    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
        software.amazon.eventstream    eventstream    1.0.1
    software.amazon.awssdk    aws-core    2.10.60
        org.slf4j    slf4j-api    1.7.28
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    auth    2.10.60
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    regions    2.10.60
                com.fasterxml.jackson.core    jackson-annotations    2.10.0
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    sdk-core    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    http-client-spi    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    profiles    2.10.60
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    sdk-core    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
            software.amazon.eventstream    eventstream    1.0.1
        software.amazon.awssdk    http-client-spi    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    regions    2.10.60
            com.fasterxml.jackson.core    jackson-annotations    2.10.0
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    sdk-core    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    sdk-core    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
        software.amazon.eventstream    eventstream    1.0.1
    software.amazon.awssdk    aws-json-protocol    2.10.60
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    aws-core    2.10.60
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    auth    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    regions    2.10.60
                    com.fasterxml.jackson.core    jackson-annotations    2.10.0
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    profiles    2.10.60
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    sdk-core    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    http-client-spi    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            software.amazon.awssdk    annotations    2.10.60
                            software.amazon.awssdk    utils    2.10.60
                                org.reactivestreams    reactive-streams    1.0.2
                                org.slf4j    slf4j-api    1.7.28
                                software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    profiles    2.10.60
                            software.amazon.awssdk    annotations    2.10.60
                            software.amazon.awssdk    utils    2.10.60
                                org.reactivestreams    reactive-streams    1.0.2
                                org.slf4j    slf4j-api    1.7.28
                                software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    sdk-core    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    http-client-spi    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    profiles    2.10.60
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
                software.amazon.eventstream    eventstream    1.0.1
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    regions    2.10.60
                com.fasterxml.jackson.core    jackson-annotations    2.10.0
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    sdk-core    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    http-client-spi    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    profiles    2.10.60
                        software.amazon.awssdk    annotations    2.10.60
                        software.amazon.awssdk    utils    2.10.60
                            org.reactivestreams    reactive-streams    1.0.2
                            org.slf4j    slf4j-api    1.7.28
                            software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    sdk-core    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
            software.amazon.eventstream    eventstream    1.0.1
        software.amazon.awssdk    http-client-spi    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    protocol-core    2.10.60
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    sdk-core    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    http-client-spi    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    profiles    2.10.60
                    software.amazon.awssdk    annotations    2.10.60
                    software.amazon.awssdk    utils    2.10.60
                        org.reactivestreams    reactive-streams    1.0.2
                        org.slf4j    slf4j-api    1.7.28
                        software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    sdk-core    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    http-client-spi    2.10.60
        org.reactivestreams    reactive-streams    1.0.2
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    protocol-core    2.10.60
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    http-client-spi    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    sdk-core    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    regions    2.10.60
        com.fasterxml.jackson.core    jackson-annotations    2.10.0
        org.slf4j    slf4j-api    1.7.28
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    profiles    2.10.60
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    sdk-core    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    http-client-spi    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    profiles    2.10.60
                software.amazon.awssdk    annotations    2.10.60
                software.amazon.awssdk    utils    2.10.60
                    org.reactivestreams    reactive-streams    1.0.2
                    org.slf4j    slf4j-api    1.7.28
                    software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    sdk-core    2.10.60
        org.reactivestreams    reactive-streams    1.0.2
        org.slf4j    slf4j-api    1.7.28
        software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    http-client-spi    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    profiles    2.10.60
            software.amazon.awssdk    annotations    2.10.60
            software.amazon.awssdk    utils    2.10.60
                org.reactivestreams    reactive-streams    1.0.2
                org.slf4j    slf4j-api    1.7.28
                software.amazon.awssdk    annotations    2.10.60
        software.amazon.awssdk    utils    2.10.60
            org.reactivestreams    reactive-streams    1.0.2
            org.slf4j    slf4j-api    1.7.28
            software.amazon.awssdk    annotations    2.10.60
    software.amazon.awssdk    utils    2.10.60
        org.reactivestreams    reactive-streams    1.0.2
        org.slf4j    slf4j-api    1.7.28
        software.amazon.awssdk    annotations    2.10.60

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 ActorSystemActorSystem and an MaterializerMaterializer.

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 AwsLambdaFlowAwsLambdaFlow 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
Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.