class Choice (construct)
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.StepFunctions.Choice |
Java | software.amazon.awscdk.services.stepfunctions.Choice |
Python | aws_cdk.aws_stepfunctions.Choice |
TypeScript (source) | @aws-cdk/aws-stepfunctions » Choice |
Implements
IConstruct
, IConstruct
, IDependable
, IChainable
Define a Choice in the state machine.
A choice state can be used to make decisions based on the execution state.
Example
import * as lambda from '@aws-cdk/aws-lambda';
declare const submitLambda: lambda.Function;
declare const getStatusLambda: lambda.Function;
const submitJob = new tasks.LambdaInvoke(this, 'Submit Job', {
lambdaFunction: submitLambda,
// Lambda's result is in the attribute `Payload`
outputPath: '$.Payload',
});
const waitX = new sfn.Wait(this, 'Wait X Seconds', {
time: sfn.WaitTime.secondsPath('$.waitSeconds'),
});
const getStatus = new tasks.LambdaInvoke(this, 'Get Job Status', {
lambdaFunction: getStatusLambda,
// Pass just the field named "guid" into the Lambda, put the
// Lambda's result in a field called "status" in the response
inputPath: '$.guid',
outputPath: '$.Payload',
});
const jobFailed = new sfn.Fail(this, 'Job Failed', {
cause: 'AWS Batch Job Failed',
error: 'DescribeJob returned FAILED',
});
const finalStatus = new tasks.LambdaInvoke(this, 'Get Final Job Status', {
lambdaFunction: getStatusLambda,
// Use "guid" field as input
inputPath: '$.guid',
outputPath: '$.Payload',
});
const definition = submitJob
.next(waitX)
.next(getStatus)
.next(new sfn.Choice(this, 'Job Complete?')
// Look at the "status" field
.when(sfn.Condition.stringEquals('$.status', 'FAILED'), jobFailed)
.when(sfn.Condition.stringEquals('$.status', 'SUCCEEDED'), finalStatus)
.otherwise(waitX));
new sfn.StateMachine(this, 'StateMachine', {
definition,
timeout: Duration.minutes(5),
});
Initializer
new Choice(scope: Construct, id: string, props?: ChoiceProps)
Parameters
- scope
Construct
- id
string
- props
Choice
Props
Construct Props
Name | Type | Description |
---|---|---|
comment? | string | An optional description for this state. |
input | string | JSONPath expression to select part of the state to be the input to this state. |
output | string | JSONPath expression to select part of the state to be the output to this state. |
comment?
Type:
string
(optional, default: No comment)
An optional description for this state.
inputPath?
Type:
string
(optional, default: $)
JSONPath expression to select part of the state to be the input to this state.
May also be the special value DISCARD, which will cause the effective input to be the empty object {}.
outputPath?
Type:
string
(optional, default: $)
JSONPath expression to select part of the state to be the output to this state.
May also be the special value DISCARD, which will cause the effective output to be the empty object {}.
Properties
Name | Type | Description |
---|---|---|
end | INextable [] | Continuable states of this Chainable. |
id | string | Descriptive identifier for this chainable. |
node | Construct | The construct tree node associated with this construct. |
start | State | First state of this Chainable. |
state | string | Tokenized string that evaluates to the state's ID. |
endStates
Type:
INextable
[]
Continuable states of this Chainable.
id
Type:
string
Descriptive identifier for this chainable.
node
Type:
Construct
The construct tree node associated with this construct.
startState
Type:
State
First state of this Chainable.
stateId
Type:
string
Tokenized string that evaluates to the state's ID.
Methods
Name | Description |
---|---|
add | Add a prefix to the stateId of this state. |
afterwards(options?) | Return a Chain that contains all reachable end states from this Choice. |
bind | Register this state as part of the given graph. |
otherwise(def) | If none of the given conditions match, continue execution with the given state. |
to | Return the Amazon States Language object for this state. |
to | Returns a string representation of this construct. |
when(condition, next) | If the given condition matches, continue execution with the given state. |
addPrefix(x)
public addPrefix(x: string): void
Parameters
- x
string
Add a prefix to the stateId of this state.
afterwards(options?)
public afterwards(options?: AfterwardsOptions): Chain
Parameters
- options
Afterwards
Options
Returns
Return a Chain that contains all reachable end states from this Choice.
Use this to combine all possible choice paths back.
bindToGraph(graph)
public bindToGraph(graph: StateGraph): void
Parameters
- graph
State
Graph
Register this state as part of the given graph.
Don't call this. It will be called automatically when you work with states normally.
otherwise(def)
public otherwise(def: IChainable): Choice
Parameters
- def
IChainable
Returns
If none of the given conditions match, continue execution with the given state.
If no conditions match and no otherwise() has been given, an execution error will be raised.
toStateJson()
public toStateJson(): json
Returns
json
Return the Amazon States Language object for this state.
toString()
public toString(): string
Returns
string
Returns a string representation of this construct.
when(condition, next)
public when(condition: Condition, next: IChainable): Choice
Parameters
- condition
Condition
- next
IChainable
Returns
If the given condition matches, continue execution with the given state.