lambda

Kubemq lambda target Connector

Kubemq aws-lambda target connector allows services using kubemq server to access aws lambda service.

Prerequisites

The following required to run the aws-lambda target connector:

• kubemq cluster
• aws account with lambda active service
• kubemq-targets deployment

Configuration

lambda target connector configuration properties:

Example:

bindings:
  - name: kubemq-query-aws-lambda
    source:
      kind: kubemq.query
      name: kubemq-query
      properties:
        address: "kubemq-cluster:50000"
        client_id: "kubemq-query-aws-lambda-connector"
        auth_token: ""
        channel: "query.aws.lambda"
        group:   ""
        auto_reconnect: "true"
        reconnect_interval_seconds: "1"
        max_reconnects: "0"
    target:
      kind: aws.lambda
      name: aws-lambda
      properties:
        aws_key: "id"
        aws_secret_key: 'json'
        region:  "region"
        token: ""

Usage

List Lambda

List all lambdas

List Lambda:

Example:

{
  "metadata": {
    "method": "list"
  },
  "data": null
}

Create Lambda

create a new lambda.

Create Lambda:

Example:

{
  "metadata": {
    "method": "create",
    "zip_file_name": "myfile.zip",
    "handler_name": "myhandler",
    "role": "arn:aws:iam::0000000:myRole",
    "runtime": "nodejs12.x",
    "function_name": "testfunction",
    "memory_size": "256",
    "timeout": "3",
    "description": "my awesome testing method"
  },
  "data": "ZXhwb3J0cy5oYW5kbGVyID0gYXN5bmMgKGV2ZW50KSA9PiB7CiAgICAvLyBUT0RPIGltcGxlbWVudAogICAgY29uc3QgcmVzcG9uc2UgPSB7CiAgICAgICAgc3RhdHVzQ29kZTogMjAwLAogICAgICAgIGJvZHk6IEpTT04uc3RyaW5naWZ5KCdIZWxsbyBmcm9tIExhbWJkYSEnKSwKICAgIH07CiAgICByZXR1cm4gcmVzcG9uc2U7Cn07Cg=="
}

Run Lambda

run a specific lambda

Run Lambda:

Example:

{
  "metadata": {
    "method": "run",
    "function_name": "testfunction",
    "dry-run": "false"
  },
  "data": "eyJ0ZXN0IjogInRlc3QifQ=="
}

Delete Lambda

Delete Lambda:

Example:

{
  "metadata": {
    "method": "delete",
    "function_name": "testfunction"
  },
  "data": null
}