// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as lambda from '@aws-cdk/aws-lambda';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
declare const function_: lambda.Function;
declare const payload: any;
const invokeFunction = new stepfunctions_tasks.InvokeFunction(function_, /* all optional props */ {
payload: {
payloadKey: payload,
},
});
import * as lambda from '@aws-cdk/aws-lambda';
declare const orderFn: lambda.Function;
const submitJob = new tasks.LambdaInvoke(this, 'InvokeOrderProcessor', {
lambdaFunction: orderFn,
payload: sfn.TaskInput.fromObject({
OrderId: sfn.JsonPath.stringAt('$.OrderId'),
}),
});
import * as cloudformation from '@aws-cdk/aws-cloudformation';
import * as lambda from '@aws-cdk/aws-lambda';
declare const myFunction: lambda.Function;
// invoke an AWS Lambda function when a lifecycle event occurs:
const provider = cloudformation.CustomResourceProvider.fromLambda(myFunction);
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
const invokeActivityProps: stepfunctions_tasks.InvokeActivityProps = {
heartbeat: cdk.Duration.minutes(30),
};
// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as stepfunctions from '@aws-cdk/aws-stepfunctions';
import * as stepfunctions_tasks from '@aws-cdk/aws-stepfunctions-tasks';
import * as cdk from '@aws-cdk/core';
declare const taskInput: stepfunctions.TaskInput;
const sendToQueueProps: stepfunctions_tasks.SendToQueueProps = {
messageBody: taskInput,
// the properties below are optional
delay: cdk.Duration.minutes(30),
integrationPattern: stepfunctions.ServiceIntegrationPattern.FIRE_AND_FORGET,
messageDeduplicationId: 'messageDeduplicationId',
messageGroupId: 'messageGroupId',
};