lambda

README

---

title: Trigger Lambda Function weight: 4614

Trigger Lambda function

This activity allows you to invoke an AWS Lambda function via ARN and provide the access key and secret for authentication.

Installation

Flogo Web

This activity comes out of the box with the Flogo Web UI

Flogo CLI

flogo add activity github.com/TIBCOSoftware/flogo-contrib/activity/lambda

Schema

Inputs and Outputs:

{
  "input":[
    {
      "name": "arn",
      "type": "string",
      "required": true
    },
    {
      "name": "region",
      "type": "string",
      "required": true
    },
    {
      "name": "accessKey",
      "type": "string",
      "required" : false
    },
    {
      "name": "secretKey",
      "type": "string",
      "required" : false
    },
    {
      "name": "payload",
      "type": "any",
      "required" : true
    }
  ],
  "output": [
    {
      "name": "value",
      "type": "any"
    },
    {
      "name": "result",
      "type": "any"
    },
    {
      "name": "status",
      "type": "integer"
    }
  ]
}

Settings

Setting	Required	Description
arn	True	The ARN of the Lambda function to invoke
region	True	The AWS region in which you want to invoke the function
accessKey	False	AWS access key for the user to invoke the function
secretKey	False	AWS secret key for the user to invoke te function
payload	True	The payload to send to the function. This must be a valid JSON object.
value	False	A struct containing the status and response
result	False	The response from the invocation
status	False	The status of the invocation

Examples

Coming soon...

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type Activity
  • func (a *Activity) Eval(context activity.Context) (done bool, err error)
  • func (a *Activity) Metadata() *activity.Metadata
• type Response

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new LambdaActivity

Types

type Activity

type Activity struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Activity is a App Activity implementation

func (*Activity) Eval

func (a *Activity) Eval(context activity.Context) (done bool, err error)

Eval implements activity.Activity.Eval

func (*Activity) Metadata

func (a *Activity) Metadata() *activity.Metadata

Metadata implements activity.Activity.Metadata

type Response

type Response struct {
	Status  int64
	Payload []byte
}

Response struct is used to store the response from Lambda