machines = response.stateMachines();
for (StateMachineListItem machine : machines) {
System.out.println("The name of the state machine is: " + machine.name());
System.out.println("The ARN value is : " + machine.stateMachineArn());
}
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
}
```
+ Para obter detalhes da API, consulte [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)a *Referência AWS SDK for Java 2.x da API*.
## Conceitos básicos
### Conheça os conceitos básicos
O exemplo de código a seguir mostra como:
+ Criar uma atividade.
+ Criar uma máquina de estado a partir de uma definição da Amazon States Language que contenha a atividade criada anteriormente como uma etapa.
+ Executar a máquina de estado e responder à atividade com entrada do usuário.
+ Obter o status e a saída finais após a conclusão da execução e, em seguida, limpar os recursos.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
/**
* You can obtain the JSON file to create a state machine in the following
* GitHub location.
*
* https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/resources/sample_files
*
* To run this code example, place the chat_sfn_state_machine.json file into
* your project's resources folder.
*
* Also, set up your development environment, including your credentials.
*
* For information, see this documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*
* This Java code example performs the following tasks:
*
* 1. Creates an activity.
* 2. Creates a state machine.
* 3. Describes the state machine.
* 4. Starts execution of the state machine and interacts with it.
* 5. Describes the execution.
* 6. Delete the activity.
* 7. Deletes the state machine.
*/
public class StepFunctionsScenario {
public static final String DASHES = new String(new char[80]).replace("\0", "-");
public static void main(String[] args) throws Exception {
final String usage = """
Usage:
Where:
roleName - The name of the IAM role to create for this state machine.
activityName - The name of an activity to create.
stateMachineName - The name of the state machine to create.
jsonFile - The location of the chat_sfn_state_machine.json file. You can located it in resources/sample_files.
""";
if (args.length != 4) {
System.out.println(usage);
System.exit(1);
}
String roleName = args[0];
String activityName = args[1];
String stateMachineName = args[2];
String jsonFile = args[3];
String polJSON = """
{
"Version":"2012-10-17",
"Statement": [
{
"Sid": "",
"Effect": "Allow",
"Principal": {
"Service": "states.amazonaws.com"
},
"Action": "sts:AssumeRole"
}
]
}
""";
Scanner sc = new Scanner(System.in);
boolean action = false;
Region region = Region.US_EAST_1;
SfnClient sfnClient = SfnClient.builder()
.region(region)
.build();
Region regionGl = Region.AWS_GLOBAL;
IamClient iam = IamClient.builder()
.region(regionGl)
.build();
System.out.println(DASHES);
System.out.println("Welcome to the AWS Step Functions example scenario.");
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("1. Create an activity.");
String activityArn = createActivity(sfnClient, activityName);
System.out.println("The ARN of the activity is " + activityArn);
System.out.println(DASHES);
// Read the file using FileInputStream
FileInputStream inputStream = new FileInputStream(jsonFile);
ObjectMapper mapper = new ObjectMapper();
JsonNode jsonNode = mapper.readValue(inputStream, JsonNode.class);
String jsonString = mapper.writeValueAsString(jsonNode);
// Modify the Resource node.
ObjectMapper objectMapper = new ObjectMapper();
JsonNode root = objectMapper.readTree(jsonString);
((ObjectNode) root.path("States").path("GetInput")).put("Resource", activityArn);
// Convert the modified Java object back to a JSON string.
String stateDefinition = objectMapper.writeValueAsString(root);
System.out.println(stateDefinition);
System.out.println(DASHES);
System.out.println("2. Create a state machine.");
String roleARN = createIAMRole(iam, roleName, polJSON);
String stateMachineArn = createMachine(sfnClient, roleARN, stateMachineName, stateDefinition);
System.out.println("The ARN of the state machine is " + stateMachineArn);
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("3. Describe the state machine.");
describeStateMachine(sfnClient, stateMachineArn);
System.out.println("What should ChatSFN call you?");
String userName = sc.nextLine();
System.out.println("Hello " + userName);
System.out.println(DASHES);
System.out.println(DASHES);
// The JSON to pass to the StartExecution call.
String executionJson = "{ \"name\" : \"" + userName + "\" }";
System.out.println(executionJson);
System.out.println("4. Start execution of the state machine and interact with it.");
String runArn = startWorkflow(sfnClient, stateMachineArn, executionJson);
System.out.println("The ARN of the state machine execution is " + runArn);
List myList;
while (!action) {
myList = getActivityTask(sfnClient, activityArn);
System.out.println("ChatSFN: " + myList.get(1));
System.out.println(userName + " please specify a value.");
String myAction = sc.nextLine();
if (myAction.compareTo("done") == 0)
action = true;
System.out.println("You have selected " + myAction);
String taskJson = "{ \"action\" : \"" + myAction + "\" }";
System.out.println(taskJson);
sendTaskSuccess(sfnClient, myList.get(0), taskJson);
}
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("5. Describe the execution.");
describeExe(sfnClient, runArn);
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("6. Delete the activity.");
deleteActivity(sfnClient, activityArn);
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("7. Delete the state machines.");
deleteMachine(sfnClient, stateMachineArn);
System.out.println(DASHES);
System.out.println(DASHES);
System.out.println("The AWS Step Functions example scenario is complete.");
System.out.println(DASHES);
}
public static String createIAMRole(IamClient iam, String rolename, String polJSON) {
try {
CreateRoleRequest request = CreateRoleRequest.builder()
.roleName(rolename)
.assumeRolePolicyDocument(polJSON)
.description("Created using the AWS SDK for Java")
.build();
CreateRoleResponse response = iam.createRole(request);
return response.role().arn();
} catch (IamException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
public static void describeExe(SfnClient sfnClient, String executionArn) {
try {
DescribeExecutionRequest executionRequest = DescribeExecutionRequest.builder()
.executionArn(executionArn)
.build();
String status = "";
boolean hasSucceeded = false;
while (!hasSucceeded) {
DescribeExecutionResponse response = sfnClient.describeExecution(executionRequest);
status = response.statusAsString();
if (status.compareTo("RUNNING") == 0) {
System.out.println("The state machine is still running, let's wait for it to finish.");
Thread.sleep(2000);
} else if (status.compareTo("SUCCEEDED") == 0) {
System.out.println("The Step Function workflow has succeeded");
hasSucceeded = true;
} else {
System.out.println("The Status is neither running or succeeded");
}
}
System.out.println("The Status is " + status);
} catch (SfnException | InterruptedException e) {
System.err.println(e.getMessage());
System.exit(1);
}
}
public static void sendTaskSuccess(SfnClient sfnClient, String token, String json) {
try {
SendTaskSuccessRequest successRequest = SendTaskSuccessRequest.builder()
.taskToken(token)
.output(json)
.build();
sfnClient.sendTaskSuccess(successRequest);
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
public static List getActivityTask(SfnClient sfnClient, String actArn) {
List myList = new ArrayList<>();
GetActivityTaskRequest getActivityTaskRequest = GetActivityTaskRequest.builder()
.activityArn(actArn)
.build();
GetActivityTaskResponse response = sfnClient.getActivityTask(getActivityTaskRequest);
myList.add(response.taskToken());
myList.add(response.input());
return myList;
}
public static void deleteActivity(SfnClient sfnClient, String actArn) {
try {
DeleteActivityRequest activityRequest = DeleteActivityRequest.builder()
.activityArn(actArn)
.build();
sfnClient.deleteActivity(activityRequest);
System.out.println("You have deleted " + actArn);
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
public static void describeStateMachine(SfnClient sfnClient, String stateMachineArn) {
try {
DescribeStateMachineRequest stateMachineRequest = DescribeStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
DescribeStateMachineResponse response = sfnClient.describeStateMachine(stateMachineRequest);
System.out.println("The name of the State machine is " + response.name());
System.out.println("The status of the State machine is " + response.status());
System.out.println("The ARN value of the State machine is " + response.stateMachineArn());
System.out.println("The role ARN value is " + response.roleArn());
} catch (SfnException e) {
System.err.println(e.getMessage());
}
}
public static void deleteMachine(SfnClient sfnClient, String stateMachineArn) {
try {
DeleteStateMachineRequest deleteStateMachineRequest = DeleteStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
sfnClient.deleteStateMachine(deleteStateMachineRequest);
DescribeStateMachineRequest describeStateMachine = DescribeStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
while (true) {
DescribeStateMachineResponse response = sfnClient.describeStateMachine(describeStateMachine);
System.out.println("The state machine is not deleted yet. The status is " + response.status());
Thread.sleep(3000);
}
} catch (SfnException | InterruptedException e) {
System.err.println(e.getMessage());
}
System.out.println(stateMachineArn + " was successfully deleted.");
}
public static String startWorkflow(SfnClient sfnClient, String stateMachineArn, String jsonEx) {
UUID uuid = UUID.randomUUID();
String uuidValue = uuid.toString();
try {
StartExecutionRequest executionRequest = StartExecutionRequest.builder()
.input(jsonEx)
.stateMachineArn(stateMachineArn)
.name(uuidValue)
.build();
StartExecutionResponse response = sfnClient.startExecution(executionRequest);
return response.executionArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
public static String createMachine(SfnClient sfnClient, String roleARN, String stateMachineName, String json) {
try {
CreateStateMachineRequest machineRequest = CreateStateMachineRequest.builder()
.definition(json)
.name(stateMachineName)
.roleArn(roleARN)
.type(StateMachineType.STANDARD)
.build();
CreateStateMachineResponse response = sfnClient.createStateMachine(machineRequest);
return response.stateMachineArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
public static String createActivity(SfnClient sfnClient, String activityName) {
try {
CreateActivityRequest activityRequest = CreateActivityRequest.builder()
.name(activityName)
.build();
CreateActivityResponse response = sfnClient.createActivity(activityRequest);
return response.activityArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
}
```
+ Para obter detalhes da API, consulte os tópicos a seguir na *Referência da API AWS SDK for Java 2.x *.
+ [CreateActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateActivity)
+ [CreateStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateStateMachine)
+ [DeleteActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteActivity)
+ [DeleteStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteStateMachine)
+ [DescribeExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeExecution)
+ [DescribeStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeStateMachine)
+ [GetActivityTask](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/GetActivityTask)
+ [ListActivities](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListActivities)
+ [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)
+ [SendTaskSuccess](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/SendTaskSuccess)
+ [StartExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StartExecution)
+ [StopExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StopExecution)
## Ações
### `CreateActivity`
O código de exemplo a seguir mostra como usar `CreateActivity`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static String createActivity(SfnClient sfnClient, String activityName) {
try {
CreateActivityRequest activityRequest = CreateActivityRequest.builder()
.name(activityName)
.build();
CreateActivityResponse response = sfnClient.createActivity(activityRequest);
return response.activityArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
```
+ Para obter detalhes da API, consulte [CreateActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateActivity)a *Referência AWS SDK for Java 2.x da API*.
### `CreateStateMachine`
O código de exemplo a seguir mostra como usar `CreateStateMachine`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static String createMachine(SfnClient sfnClient, String roleARN, String stateMachineName, String json) {
try {
CreateStateMachineRequest machineRequest = CreateStateMachineRequest.builder()
.definition(json)
.name(stateMachineName)
.roleArn(roleARN)
.type(StateMachineType.STANDARD)
.build();
CreateStateMachineResponse response = sfnClient.createStateMachine(machineRequest);
return response.stateMachineArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
```
+ Para obter detalhes da API, consulte [CreateStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateStateMachine)a *Referência AWS SDK for Java 2.x da API*.
### `DeleteActivity`
O código de exemplo a seguir mostra como usar `DeleteActivity`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void deleteActivity(SfnClient sfnClient, String actArn) {
try {
DeleteActivityRequest activityRequest = DeleteActivityRequest.builder()
.activityArn(actArn)
.build();
sfnClient.deleteActivity(activityRequest);
System.out.println("You have deleted " + actArn);
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
```
+ Para obter detalhes da API, consulte [DeleteActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteActivity)a *Referência AWS SDK for Java 2.x da API*.
### `DeleteStateMachine`
O código de exemplo a seguir mostra como usar `DeleteStateMachine`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void deleteMachine(SfnClient sfnClient, String stateMachineArn) {
try {
DeleteStateMachineRequest deleteStateMachineRequest = DeleteStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
sfnClient.deleteStateMachine(deleteStateMachineRequest);
DescribeStateMachineRequest describeStateMachine = DescribeStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
while (true) {
DescribeStateMachineResponse response = sfnClient.describeStateMachine(describeStateMachine);
System.out.println("The state machine is not deleted yet. The status is " + response.status());
Thread.sleep(3000);
}
} catch (SfnException | InterruptedException e) {
System.err.println(e.getMessage());
}
System.out.println(stateMachineArn + " was successfully deleted.");
}
```
+ Para obter detalhes da API, consulte [DeleteStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteStateMachine)a *Referência AWS SDK for Java 2.x da API*.
### `DescribeExecution`
O código de exemplo a seguir mostra como usar `DescribeExecution`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void describeExe(SfnClient sfnClient, String executionArn) {
try {
DescribeExecutionRequest executionRequest = DescribeExecutionRequest.builder()
.executionArn(executionArn)
.build();
String status = "";
boolean hasSucceeded = false;
while (!hasSucceeded) {
DescribeExecutionResponse response = sfnClient.describeExecution(executionRequest);
status = response.statusAsString();
if (status.compareTo("RUNNING") == 0) {
System.out.println("The state machine is still running, let's wait for it to finish.");
Thread.sleep(2000);
} else if (status.compareTo("SUCCEEDED") == 0) {
System.out.println("The Step Function workflow has succeeded");
hasSucceeded = true;
} else {
System.out.println("The Status is neither running or succeeded");
}
}
System.out.println("The Status is " + status);
} catch (SfnException | InterruptedException e) {
System.err.println(e.getMessage());
System.exit(1);
}
}
```
+ Para obter detalhes da API, consulte [DescribeExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeExecution)a *Referência AWS SDK for Java 2.x da API*.
### `DescribeStateMachine`
O código de exemplo a seguir mostra como usar `DescribeStateMachine`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void describeStateMachine(SfnClient sfnClient, String stateMachineArn) {
try {
DescribeStateMachineRequest stateMachineRequest = DescribeStateMachineRequest.builder()
.stateMachineArn(stateMachineArn)
.build();
DescribeStateMachineResponse response = sfnClient.describeStateMachine(stateMachineRequest);
System.out.println("The name of the State machine is " + response.name());
System.out.println("The status of the State machine is " + response.status());
System.out.println("The ARN value of the State machine is " + response.stateMachineArn());
System.out.println("The role ARN value is " + response.roleArn());
} catch (SfnException e) {
System.err.println(e.getMessage());
}
}
```
+ Para obter detalhes da API, consulte [DescribeStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeStateMachine)a *Referência AWS SDK for Java 2.x da API*.
### `GetActivityTask`
O código de exemplo a seguir mostra como usar `GetActivityTask`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static List getActivityTask(SfnClient sfnClient, String actArn) {
List myList = new ArrayList<>();
GetActivityTaskRequest getActivityTaskRequest = GetActivityTaskRequest.builder()
.activityArn(actArn)
.build();
GetActivityTaskResponse response = sfnClient.getActivityTask(getActivityTaskRequest);
myList.add(response.taskToken());
myList.add(response.input());
return myList;
}
```
+ Para obter detalhes da API, consulte [GetActivityTask](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/GetActivityTask)a *Referência AWS SDK for Java 2.x da API*.
### `ListActivities`
O código de exemplo a seguir mostra como usar `ListActivities`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sfn.SfnClient;
import software.amazon.awssdk.services.sfn.model.ListActivitiesRequest;
import software.amazon.awssdk.services.sfn.model.ListActivitiesResponse;
import software.amazon.awssdk.services.sfn.model.SfnException;
import software.amazon.awssdk.services.sfn.model.ActivityListItem;
import java.util.List;
/**
* Before running this Java V2 code example, set up your development
* environment, including your credentials.
*
* For more information, see the following documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*/
public class ListActivities {
public static void main(String[] args) {
Region region = Region.US_EAST_1;
SfnClient sfnClient = SfnClient.builder()
.region(region)
.build();
listAllActivites(sfnClient);
sfnClient.close();
}
public static void listAllActivites(SfnClient sfnClient) {
try {
ListActivitiesRequest activitiesRequest = ListActivitiesRequest.builder()
.maxResults(10)
.build();
ListActivitiesResponse response = sfnClient.listActivities(activitiesRequest);
List items = response.activities();
for (ActivityListItem item : items) {
System.out.println("The activity ARN is " + item.activityArn());
System.out.println("The activity name is " + item.name());
}
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
}
```
+ Para obter detalhes da API, consulte [ListActivities](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListActivities)a *Referência AWS SDK for Java 2.x da API*.
### `ListExecutions`
O código de exemplo a seguir mostra como usar `ListExecutions`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void getExeHistory(SfnClient sfnClient, String exeARN) {
try {
GetExecutionHistoryRequest historyRequest = GetExecutionHistoryRequest.builder()
.executionArn(exeARN)
.maxResults(10)
.build();
GetExecutionHistoryResponse historyResponse = sfnClient.getExecutionHistory(historyRequest);
List events = historyResponse.events();
for (HistoryEvent event : events) {
System.out.println("The event type is " + event.type().toString());
}
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
```
+ Para obter detalhes da API, consulte [ListExecutions](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListExecutions)a *Referência AWS SDK for Java 2.x da API*.
### `ListStateMachines`
O código de exemplo a seguir mostra como usar `ListStateMachines`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sfn.SfnClient;
import software.amazon.awssdk.services.sfn.model.ListStateMachinesResponse;
import software.amazon.awssdk.services.sfn.model.SfnException;
import software.amazon.awssdk.services.sfn.model.StateMachineListItem;
import java.util.List;
/**
* Before running this Java V2 code example, set up your development
* environment, including your credentials.
*
* For more information, see the following documentation topic:
*
* https://docs.aws.amazon.com/sdk-for-java/latest/developer-guide/get-started.html
*/
public class ListStateMachines {
public static void main(String[] args) {
Region region = Region.US_EAST_1;
SfnClient sfnClient = SfnClient.builder()
.region(region)
.build();
listMachines(sfnClient);
sfnClient.close();
}
public static void listMachines(SfnClient sfnClient) {
try {
ListStateMachinesResponse response = sfnClient.listStateMachines();
List machines = response.stateMachines();
for (StateMachineListItem machine : machines) {
System.out.println("The name of the state machine is: " + machine.name());
System.out.println("The ARN value is : " + machine.stateMachineArn());
}
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
}
```
+ Para obter detalhes da API, consulte [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)a *Referência AWS SDK for Java 2.x da API*.
### `SendTaskSuccess`
O código de exemplo a seguir mostra como usar `SendTaskSuccess`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static void sendTaskSuccess(SfnClient sfnClient, String token, String json) {
try {
SendTaskSuccessRequest successRequest = SendTaskSuccessRequest.builder()
.taskToken(token)
.output(json)
.build();
sfnClient.sendTaskSuccess(successRequest);
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
```
+ Para obter detalhes da API, consulte [SendTaskSuccess](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/SendTaskSuccess)a *Referência AWS SDK for Java 2.x da API*.
### `StartExecution`
O código de exemplo a seguir mostra como usar `StartExecution`.
**SDK para Java 2.x**
Tem mais sobre GitHub. Encontre o exemplo completo e saiba como configurar e executar no [AWS Code Examples Repository](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/example_code/stepfunctions#code-examples).
```
public static String startWorkflow(SfnClient sfnClient, String stateMachineArn, String jsonEx) {
UUID uuid = UUID.randomUUID();
String uuidValue = uuid.toString();
try {
StartExecutionRequest executionRequest = StartExecutionRequest.builder()
.input(jsonEx)
.stateMachineArn(stateMachineArn)
.name(uuidValue)
.build();
StartExecutionResponse response = sfnClient.startExecution(executionRequest);
return response.executionArn();
} catch (SfnException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
return "";
}
```
+ Para obter detalhes da API, consulte [StartExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StartExecution)a *Referência AWS SDK for Java 2.x da API*.
## Cenários
### Usar Step Functions para invocar funções do Lambda
O exemplo de código a seguir mostra como criar uma máquina de AWS Step Functions estado que invoca AWS Lambda funções em sequência.
**SDK para Java 2.x**
Mostra como criar um fluxo de trabalho AWS sem servidor usando AWS Step Functions e. AWS SDK for Java 2.x Cada etapa do fluxo de trabalho é implementada usando uma AWS Lambda função.
Para obter o código-fonte completo e instruções sobre como configurar e executar, veja o exemplo completo em [GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/usecases/creating_workflows_stepfunctions).
**Serviços usados neste exemplo**
+ DynamoDB
+ Lambda
+ Amazon SES
+ Step Functions