A Step Function state machine construct focused on working well with the Workflow Studio
Project description
Workflow Studio compatible State Machine
This is a Workflow Studio compatible AWS Step Function state machine construct.
The goal of this construct is to make it easy to build and maintain your state machines using the Workflow Studio but still leverage the AWS CDK as the source of truth for the state machine.
Read more about it here.
How to Use This Construct
Start by designing your initial state machine using the Workflow Studio. When done with your first draft, copy and paste the ASL definition to a local file.
Create a new instance of this construct, handing it a fully parsed version of the ASL.
Then add overridden values.
The fields in the overrides
field should match the States
field of the ASL.
Projen component
There is a projen component included in this library which will help you in using the construct. It works similar to the auto-discovery feature. To use it, first add the component to your projen project:
// ...
const { StepFunctionsAutoDiscover } = require('@matthewbonig/state-machine');
const project = new awscdk.AwsCdkTypeScriptApp({
// ...,
deps: [
// ...,
'@matthewbonig/state-machine',
]
});
new StepFunctionsAutoDiscover(project);
Now projen will look for any files with a suffix .workflow.json
and generate new files beside the .json:
- A typed overrides interface which is based on your workflow.
- A construct derived from StateMachine that uses this override.
Instead of using the StateMachine construct directly you can now use the generated one:
.
├── MyFancyThing.workflow.json
└── MyFancyThing-statemachine.ts
export class SomeStack extends Stack {
constructor(scope: Construct, id: string, props: StackProps) {
super(scope, id, props);
const handler = new NodejsFunction(this, 'MyHandler');
new SomeFancyThingStateMachine(this, 'MyFancyWorkflow', {
overrides: {
'My First State': {
Parameters: {
FunctionName: handler.functionName
}
}
}
})
}
}
:warning: The interfaces and constructs generated here are NOT jsii compliant (they use Partials and Omits) and cannot be compiled by jsii into other languages. If you plan to distribute any libraries you cannot use this.
Examples
const secret = new Secret(stack, 'Secret', {});
new StateMachine(stack, 'Test', {
stateMachineName: 'A nice state machine',
definition: JSON.parse(fs.readFileSync(path.join(__dirname, 'sample.json'), 'utf8').toString()),
overrides: {
'Read database credentials secret': {
Parameters: {
SecretId: secret.secretArn,
},
},
},
});
You can also override nested states in arrays, for example:
new StateMachine(stack, 'Test', {
stateMachineName: 'A-nice-state-machine',
overrides: {
Branches: [{
// pass an empty object too offset overrides
}, {
StartAt: 'StartInstances',
States: {
StartInstances: {
Parameters: {
InstanceIds: ['INSTANCE_ID'],
},
},
},
}],
},
stateMachineType: StateMachineType.STANDARD,
definition: {
States: {
Branches: [
{
StartAt: 'ResumeCluster',
States: {
'Redshift Pass': {
Type: 'Pass',
End: true,
},
},
},
{
StartAt: 'StartInstances',
States: {
'StartInstances': {
Type: 'Task',
Parameters: {
InstanceIds: [
'MyData',
],
},
Resource: 'arn:aws:states:::aws-sdk:ec2:startInstances',
Next: 'DescribeInstanceStatus',
},
'DescribeInstanceStatus': {
Type: 'Task',
Next: 'EC2 Pass',
Parameters: {
InstanceIds: [
'MyData',
],
},
Resource: 'arn:aws:states:::aws-sdk:ec2:describeInstanceStatus',
},
'EC2 Pass': {
Type: 'Pass',
End: true,
},
},
},
],
},
},
});
For Python, be sure to use a context manager when opening your JSON file.
- You do not need to
str()
the dictionary object you supply as yourdefinition
prop. - Elements of your override path do need to be strings.
secret = Secret(stack, 'Secret')
with open('sample.json', 'r+', encoding='utf-8') as sample:
sample_dict = json.load(sample)
state_machine = StateMachine(
self,
'Test',
definition = sample_dict,
overrides = {
"Read database credentials secret": {
"Parameters": {
"SecretId": secret.secret_arn,
},
},
})
In this example, the ASL has a state called 'Read database credentials secret' and the SecretId parameter is overridden with a CDK generated value. Future changes can be done by editing, debugging, and testing the state machine directly in the Workflow Studio. Once everything is working properly, copy and paste the ASL back to your local file.
Issues
Please open any issues you have on Github.
Contributing
Please submit PRs from forked repositories if you'd like to contribute.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for mbonig.state-machine-0.0.19.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 25434fad350cdabe462d61074e449db654e1c523fc8995b7ea0aa8fb95adb140 |
|
MD5 | 7b42b531d179ced1111fd3b5733ecc83 |
|
BLAKE2b-256 | fd02dd92dc544d1d18bf11bf901b0b27ddaad59e2a020e066e474f21f686e6ab |
Hashes for mbonig.state_machine-0.0.19-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | dbdc95c6f1ef68a628f0ab9ecfff194728b2a65d312422866002fbdedd67094e |
|
MD5 | 5b4662a8c7007aa56f5bde297822c5d5 |
|
BLAKE2b-256 | ca54282dcf427a341509f65e61dbc3f5319e941834cd19bd9c063fd7de9c29a4 |