StopExecution(string executionArn)
{
var response =
await _amazonStepFunctions.StopExecutionAsync(new StopExecutionRequest { ExecutionArn = executionArn });
return response.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
}
```
+ Para obtener detalles sobre la API, consulte los siguientes temas en la *Referencia de la API de AWS SDK para .NET *.
+ [CreateActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateActivity)
+ [CreateStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateStateMachine)
+ [DeleteActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteActivity)
+ [DeleteStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteStateMachine)
+ [DescribeExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeExecution)
+ [DescribeStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeStateMachine)
+ [GetActivityTask](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/GetActivityTask)
+ [ListActivities](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListActivities)
+ [ListStateMachines](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListStateMachines)
+ [SendTaskSuccess](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/SendTaskSuccess)
+ [StartExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/StartExecution)
+ [StopExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/StopExecution)
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener detalles sobre la API, consulte los siguientes temas en la *Referencia de la API de 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)
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
import aws.sdk.kotlin.services.iam.IamClient
import aws.sdk.kotlin.services.iam.model.CreateRoleRequest
import aws.sdk.kotlin.services.sfn.SfnClient
import aws.sdk.kotlin.services.sfn.model.CreateActivityRequest
import aws.sdk.kotlin.services.sfn.model.CreateStateMachineRequest
import aws.sdk.kotlin.services.sfn.model.DeleteActivityRequest
import aws.sdk.kotlin.services.sfn.model.DeleteStateMachineRequest
import aws.sdk.kotlin.services.sfn.model.DescribeExecutionRequest
import aws.sdk.kotlin.services.sfn.model.DescribeStateMachineRequest
import aws.sdk.kotlin.services.sfn.model.GetActivityTaskRequest
import aws.sdk.kotlin.services.sfn.model.ListActivitiesRequest
import aws.sdk.kotlin.services.sfn.model.ListStateMachinesRequest
import aws.sdk.kotlin.services.sfn.model.SendTaskSuccessRequest
import aws.sdk.kotlin.services.sfn.model.StartExecutionRequest
import aws.sdk.kotlin.services.sfn.model.StateMachineType
import aws.sdk.kotlin.services.sfn.paginators.listActivitiesPaginated
import aws.sdk.kotlin.services.sfn.paginators.listStateMachinesPaginated
import com.fasterxml.jackson.databind.JsonNode
import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.databind.node.ObjectNode
import kotlinx.coroutines.flow.transform
import java.util.Scanner
import java.util.UUID
import kotlin.collections.ArrayList
import kotlin.system.exitProcess
/**
To run this code example, place the chat_sfn_state_machine.json file into your project's resources folder.
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
Before running this Kotlin 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-kotlin/latest/developer-guide/setup.html
This Kotlin code example performs the following tasks:
1. List activities using a paginator.
2. List state machines using a paginator.
3. Creates an activity.
4. Creates a state machine.
5. Describes the state machine.
6. Starts execution of the state machine and interacts with it.
7. Describes the execution.
8. Deletes the activity.
9. Deletes the state machine.
*/
val DASHES: String = String(CharArray(80)).replace("\u0000", "-")
suspend fun main(args: Array) {
val 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.size != 4) {
println(usage)
exitProcess(0)
}
val roleName = args[0]
val activityName = args[1]
val stateMachineName = args[2]
val jsonFile = args[3]
val sc = Scanner(System.`in`)
var action = false
val polJSON = """{
"Version":"2012-10-17",
"Statement": [
{
"Sid": "",
"Effect": "Allow",
"Principal": {
"Service": "states.amazonaws.com"
},
"Action": "sts:AssumeRole"
}
]
}"""
println(DASHES)
println("Welcome to the AWS Step Functions example scenario.")
println(DASHES)
println(DASHES)
println("1. List activities using a Paginator.")
listActivitesPagnator()
println(DASHES)
println(DASHES)
println("2. List state machines using a paginator.")
listStatemachinesPagnator()
println(DASHES)
println(DASHES)
println("3. Create a new activity.")
val activityArn = createActivity(activityName)
println("The ARN of the Activity is $activityArn")
println(DASHES)
// Get JSON to use for the state machine and place the activityArn value into it.
val stream = GetStream()
val jsonString = stream.getStream(jsonFile)
// Modify the Resource node.
val objectMapper = ObjectMapper()
val root: JsonNode = objectMapper.readTree(jsonString)
(root.path("States").path("GetInput") as ObjectNode).put("Resource", activityArn)
// Convert the modified Java object back to a JSON string.
val stateDefinition = objectMapper.writeValueAsString(root)
println(stateDefinition)
println(DASHES)
println("4. Create a state machine.")
val roleARN = createIAMRole(roleName, polJSON)
val stateMachineArn = createMachine(roleARN, stateMachineName, stateDefinition)
println("The ARN of the state machine is $stateMachineArn")
println(DASHES)
println(DASHES)
println("5. Describe the state machine.")
describeStateMachine(stateMachineArn)
println("What should ChatSFN call you?")
val userName = sc.nextLine()
println("Hello $userName")
println(DASHES)
println(DASHES)
// The JSON to pass to the StartExecution call.
val executionJson = "{ \"name\" : \"$userName\" }"
println(executionJson)
println("6. Start execution of the state machine and interact with it.")
val runArn = startWorkflow(stateMachineArn, executionJson)
println("The ARN of the state machine execution is $runArn")
var myList: List
while (!action) {
myList = getActivityTask(activityArn)
println("ChatSFN: " + myList[1])
println("$userName please specify a value.")
val myAction = sc.nextLine()
if (myAction.compareTo("done") == 0) {
action = true
}
println("You have selected $myAction")
val taskJson = "{ \"action\" : \"$myAction\" }"
println(taskJson)
sendTaskSuccess(myList[0], taskJson)
}
println(DASHES)
println(DASHES)
println("7. Describe the execution.")
describeExe(runArn)
println(DASHES)
println(DASHES)
println("8. Delete the activity.")
deleteActivity(activityArn)
println(DASHES)
println(DASHES)
println("9. Delete the state machines.")
deleteMachine(stateMachineArn)
println(DASHES)
println(DASHES)
println("The AWS Step Functions example scenario is complete.")
println(DASHES)
}
suspend fun listStatemachinesPagnator() {
val machineRequest =
ListStateMachinesRequest {
maxResults = 10
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient
.listStateMachinesPaginated(machineRequest)
.transform { it.stateMachines?.forEach { obj -> emit(obj) } }
.collect { obj ->
println(" The state machine ARN is ${obj.stateMachineArn}")
}
}
}
suspend fun listActivitesPagnator() {
val activitiesRequest =
ListActivitiesRequest {
maxResults = 10
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient
.listActivitiesPaginated(activitiesRequest)
.transform { it.activities?.forEach { obj -> emit(obj) } }
.collect { obj ->
println(" The activity ARN is ${obj.activityArn}")
}
}
}
suspend fun deleteMachine(stateMachineArnVal: String?) {
val deleteStateMachineRequest =
DeleteStateMachineRequest {
stateMachineArn = stateMachineArnVal
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.deleteStateMachine(deleteStateMachineRequest)
println("$stateMachineArnVal was successfully deleted.")
}
}
suspend fun deleteActivity(actArn: String?) {
val activityRequest =
DeleteActivityRequest {
activityArn = actArn
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.deleteActivity(activityRequest)
println("You have deleted $actArn")
}
}
suspend fun describeExe(executionArnVal: String?) {
val executionRequest =
DescribeExecutionRequest {
executionArn = executionArnVal
}
var status = ""
var hasSucceeded = false
while (!hasSucceeded) {
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.describeExecution(executionRequest)
status = response.status.toString()
if (status.compareTo("Running") == 0) {
println("The state machine is still running, let's wait for it to finish.")
Thread.sleep(2000)
} else if (status.compareTo("Succeeded") == 0) {
println("The Step Function workflow has succeeded")
hasSucceeded = true
} else {
println("The Status is $status")
}
}
}
println("The Status is $status")
}
suspend fun sendTaskSuccess(
token: String?,
json: String?,
) {
val successRequest =
SendTaskSuccessRequest {
taskToken = token
output = json
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.sendTaskSuccess(successRequest)
}
}
suspend fun getActivityTask(actArn: String?): List {
val myList: MutableList = ArrayList()
val getActivityTaskRequest =
GetActivityTaskRequest {
activityArn = actArn
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.getActivityTask(getActivityTaskRequest)
myList.add(response.taskToken.toString())
myList.add(response.input.toString())
return myList
}
}
suspend fun startWorkflow(
stateMachineArnVal: String?,
jsonEx: String?,
): String? {
val uuid = UUID.randomUUID()
val uuidValue = uuid.toString()
val executionRequest =
StartExecutionRequest {
input = jsonEx
stateMachineArn = stateMachineArnVal
name = uuidValue
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.startExecution(executionRequest)
return response.executionArn
}
}
suspend fun describeStateMachine(stateMachineArnVal: String?) {
val stateMachineRequest =
DescribeStateMachineRequest {
stateMachineArn = stateMachineArnVal
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.describeStateMachine(stateMachineRequest)
println("The name of the State machine is ${response.name}")
println("The status of the State machine is ${response.status}")
println("The ARN value of the State machine is ${response.stateMachineArn}")
println("The role ARN value is ${response.roleArn}")
}
}
suspend fun createMachine(
roleARNVal: String?,
stateMachineName: String?,
jsonVal: String?,
): String? {
val machineRequest =
CreateStateMachineRequest {
definition = jsonVal
name = stateMachineName
roleArn = roleARNVal
type = StateMachineType.Standard
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.createStateMachine(machineRequest)
return response.stateMachineArn
}
}
suspend fun createIAMRole(
roleNameVal: String?,
polJSON: String?,
): String? {
val request =
CreateRoleRequest {
roleName = roleNameVal
assumeRolePolicyDocument = polJSON
description = "Created using the AWS SDK for Kotlin"
}
IamClient.fromEnvironment { region = "AWS_GLOBAL" }.use { iamClient ->
val response = iamClient.createRole(request)
return response.role?.arn
}
}
suspend fun createActivity(activityName: String): String? {
val activityRequest =
CreateActivityRequest {
name = activityName
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.createActivity(activityRequest)
return response.activityArn
}
}
```
+ Para obtener detalles sobre la API, consulte los siguientes temas en la *Referencia de la API de AWS SDK para Kotlin*.
+ [CreateActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [CreateStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DeleteActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DeleteStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DescribeExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [DescribeStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [GetActivityTask](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [ListActivities](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [ListStateMachines](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [SendTaskSuccess](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [StartExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
+ [StopExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
Ejecutar un escenario interactivo en un símbolo del sistema.
```
class StateMachineScenario:
"""Runs an interactive scenario that shows how to get started using Step Functions."""
def __init__(self, activity, state_machine, iam_client):
"""
:param activity: An object that wraps activity actions.
:param state_machine: An object that wraps state machine actions.
:param iam_client: A Boto3 AWS Identity and Access Management (IAM) client.
"""
self.activity = activity
self.state_machine = state_machine
self.iam_client = iam_client
self.state_machine_role = None
def prerequisites(self, state_machine_role_name):
"""
Finds or creates an IAM role that can be assumed by Step Functions.
A role of this kind is required to create a state machine.
The state machine used in this example does not call any additional services,
so it needs no additional permissions.
:param state_machine_role_name: The name of the role.
:return: Data about the role.
"""
trust_policy = {
"Version":"2012-10-17",
"Statement": [
{
"Sid": "",
"Effect": "Allow",
"Principal": {"Service": "states.amazonaws.com"},
"Action": "sts:AssumeRole",
}
],
}
try:
role = self.iam_client.get_role(RoleName=state_machine_role_name)
print(f"Prerequisite IAM role {state_machine_role_name} already exists.")
except ClientError as err:
if err.response["Error"]["Code"] == "NoSuchEntity":
role = None
else:
logger.error(
"Couldn't get prerequisite IAM role %s. Here's why: %s: %s",
state_machine_role_name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
if role is None:
try:
role = self.iam_client.create_role(
RoleName=state_machine_role_name,
AssumeRolePolicyDocument=json.dumps(trust_policy),
)
except ClientError as err:
logger.error(
"Couldn't create prerequisite IAM role %s. Here's why: %s: %s",
state_machine_role_name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
self.state_machine_role = role["Role"]
def find_or_create_activity(self, activity_name):
"""
Finds or creates a Step Functions activity.
:param activity_name: The name of the activity.
:return: The Amazon Resource Name (ARN) of the activity.
"""
print("First, let's set up an activity and state machine.")
activity_arn = self.activity.find(activity_name)
if activity_arn is None:
activity_arn = self.activity.create(activity_name)
print(
f"Activity {activity_name} created. Its Amazon Resource Name (ARN) is "
f"{activity_arn}."
)
else:
print(f"Activity {activity_name} already exists.")
return activity_arn
def find_or_create_state_machine(
self, state_machine_name, activity_arn, state_machine_file
):
"""
Finds or creates a Step Functions state machine.
:param state_machine_name: The name of the state machine.
:param activity_arn: The ARN of an activity that is used as a step in the state
machine. This ARN is injected into the state machine
definition that's used to create the state machine.
:param state_machine_file: The path to a file containing the state machine
definition.
:return: The ARN of the state machine.
"""
state_machine_arn = self.state_machine.find(state_machine_name)
if state_machine_arn is None:
with open(state_machine_file) as state_machine_file:
state_machine_def = state_machine_file.read().replace(
"{{DOC_EXAMPLE_ACTIVITY_ARN}}", activity_arn
)
state_machine_arn = self.state_machine.create(
state_machine_name,
state_machine_def,
self.state_machine_role["Arn"],
)
print(f"State machine {state_machine_name} created.")
else:
print(f"State machine {state_machine_name} already exists.")
print("-" * 88)
print(f"Here's some information about state machine {state_machine_name}:")
state_machine_info = self.state_machine.describe(state_machine_arn)
for field in ["name", "status", "stateMachineArn", "roleArn"]:
print(f"\t{field}: {state_machine_info[field]}")
return state_machine_arn
def run_state_machine(self, state_machine_arn, activity_arn):
"""
Run the state machine. The state machine used in this example is a simple
chat simulation. It contains an activity step in a loop that is used for user
interaction. When the state machine gets to the activity step, it waits for
an external application to get task data and submit a response. This function
acts as the activity application by getting task input and responding with
user input.
:param state_machine_arn: The ARN of the state machine.
:param activity_arn: The ARN of the activity used as a step in the state machine.
:return: The ARN of the run.
"""
print(
f"Let's run the state machine. It's a simplistic, non-AI chat simulator "
f"we'll call ChatSFN."
)
user_name = q.ask("What should ChatSFN call you? ", q.non_empty)
run_input = {"name": user_name}
print("Starting state machine...")
run_arn = self.state_machine.start(state_machine_arn, json.dumps(run_input))
action = None
while action != "done":
activity_task = self.activity.get_task(activity_arn)
task_input = json.loads(activity_task["input"])
print(f"ChatSFN: {task_input['message']}")
action = task_input["actions"][
q.choose("What now? ", task_input["actions"])
]
task_response = {"action": action}
self.activity.send_task_success(
activity_task["taskToken"], json.dumps(task_response)
)
return run_arn
def finish_state_machine_run(self, run_arn):
"""
Wait for the state machine run to finish, then print final status and output.
:param run_arn: The ARN of the run to retrieve.
"""
print(f"Let's get the final output from the state machine:")
status = "RUNNING"
while status == "RUNNING":
run_output = self.state_machine.describe_run(run_arn)
status = run_output["status"]
if status == "RUNNING":
print(
"The state machine is still running, let's wait for it to finish."
)
wait(1)
elif status == "SUCCEEDED":
print(f"ChatSFN: {json.loads(run_output['output'])['message']}")
else:
print(f"Run status: {status}.")
def cleanup(
self,
state_machine_name,
state_machine_arn,
activity_name,
activity_arn,
state_machine_role_name,
):
"""
Clean up resources created by this example.
:param state_machine_name: The name of the state machine.
:param state_machine_arn: The ARN of the state machine.
:param activity_name: The name of the activity.
:param activity_arn: The ARN of the activity.
:param state_machine_role_name: The name of the role used by the state machine.
"""
if q.ask(
"Do you want to delete the state machine, activity, and role created for this "
"example? (y/n) ",
q.is_yesno,
):
self.state_machine.delete(state_machine_arn)
print(f"Deleted state machine {state_machine_name}.")
self.activity.delete(activity_arn)
print(f"Deleted activity {activity_name}.")
self.iam_client.delete_role(RoleName=state_machine_role_name)
print(f"Deleted role {state_machine_role_name}.")
def run_scenario(self, activity_name, state_machine_name):
print("-" * 88)
print("Welcome to the AWS Step Functions state machines demo.")
print("-" * 88)
activity_arn = self.find_or_create_activity(activity_name)
state_machine_arn = self.find_or_create_state_machine(
state_machine_name,
activity_arn,
"../../../resources/sample_files/chat_sfn_state_machine.json",
)
print("-" * 88)
run_arn = self.run_state_machine(state_machine_arn, activity_arn)
print("-" * 88)
self.finish_state_machine_run(run_arn)
print("-" * 88)
self.cleanup(
state_machine_name,
state_machine_arn,
activity_name,
activity_arn,
self.state_machine_role["RoleName"],
)
print("-" * 88)
print("\nThanks for watching!")
print("-" * 88)
if __name__ == "__main__":
logging.basicConfig(level=logging.INFO, format="%(levelname)s: %(message)s")
try:
stepfunctions_client = boto3.client("stepfunctions")
iam_client = boto3.client("iam")
scenario = StateMachineScenario(
Activity(stepfunctions_client),
StateMachine(stepfunctions_client),
iam_client,
)
scenario.prerequisites("doc-example-state-machine-chat")
scenario.run_scenario("doc-example-activity", "doc-example-state-machine")
except Exception:
logging.exception("Something went wrong with the demo.")
```
Definir una clase que contenga las acciones de máquina de estado.
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def create(self, name, definition, role_arn):
"""
Creates a state machine with the specific definition. The state machine assumes
the provided role before it starts a run.
:param name: The name to give the state machine.
:param definition: The Amazon States Language definition of the steps in the
the state machine.
:param role_arn: The Amazon Resource Name (ARN) of the role that is assumed by
Step Functions when the state machine is run.
:return: The ARN of the newly created state machine.
"""
try:
response = self.stepfunctions_client.create_state_machine(
name=name, definition=definition, roleArn=role_arn
)
except ClientError as err:
logger.error(
"Couldn't create state machine %s. Here's why: %s: %s",
name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["stateMachineArn"]
def find(self, name):
"""
Find a state machine by name. This requires listing the state machines until
one is found with a matching name.
:param name: The name of the state machine to search for.
:return: The ARN of the state machine if found; otherwise, None.
"""
try:
paginator = self.stepfunctions_client.get_paginator("list_state_machines")
for page in paginator.paginate():
for state_machine in page.get("stateMachines", []):
if state_machine["name"] == name:
return state_machine["stateMachineArn"]
except ClientError as err:
logger.error(
"Couldn't list state machines. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def describe(self, state_machine_arn):
"""
Get data about a state machine.
:param state_machine_arn: The ARN of the state machine to look up.
:return: The retrieved state machine data.
"""
try:
response = self.stepfunctions_client.describe_state_machine(
stateMachineArn=state_machine_arn
)
except ClientError as err:
logger.error(
"Couldn't describe state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
def start(self, state_machine_arn, run_input):
"""
Start a run of a state machine with a specified input. A run is also known
as an "execution" in Step Functions.
:param state_machine_arn: The ARN of the state machine to run.
:param run_input: The input to the state machine, in JSON format.
:return: The ARN of the run. This can be used to get information about the run,
including its current status and final output.
"""
try:
response = self.stepfunctions_client.start_execution(
stateMachineArn=state_machine_arn, input=run_input
)
except ClientError as err:
logger.error(
"Couldn't start state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["executionArn"]
def describe_run(self, run_arn):
"""
Get data about a state machine run, such as its current status or final output.
:param run_arn: The ARN of the run to look up.
:return: The retrieved run data.
"""
try:
response = self.stepfunctions_client.describe_execution(
executionArn=run_arn
)
except ClientError as err:
logger.error(
"Couldn't describe run %s. Here's why: %s: %s",
run_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
def delete(self, state_machine_arn):
"""
Delete a state machine and all of its run data.
:param state_machine_arn: The ARN of the state machine to delete.
"""
try:
response = self.stepfunctions_client.delete_state_machine(
stateMachineArn=state_machine_arn
)
except ClientError as err:
logger.error(
"Couldn't delete state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
Definir una clase que contenga las acciones de actividad.
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def create(self, name):
"""
Create an activity.
:param name: The name of the activity to create.
:return: The Amazon Resource Name (ARN) of the newly created activity.
"""
try:
response = self.stepfunctions_client.create_activity(name=name)
except ClientError as err:
logger.error(
"Couldn't create activity %s. Here's why: %s: %s",
name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["activityArn"]
def find(self, name):
"""
Find an activity by name. This requires listing activities until one is found
with a matching name.
:param name: The name of the activity to search for.
:return: If found, the ARN of the activity; otherwise, None.
"""
try:
paginator = self.stepfunctions_client.get_paginator("list_activities")
for page in paginator.paginate():
for activity in page.get("activities", []):
if activity["name"] == name:
return activity["activityArn"]
except ClientError as err:
logger.error(
"Couldn't list activities. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def get_task(self, activity_arn):
"""
Gets task data for an activity. When a state machine is waiting for the
specified activity, a response is returned with data from the state machine.
When a state machine is not waiting, this call blocks for 60 seconds.
:param activity_arn: The ARN of the activity to get task data for.
:return: The task data for the activity.
"""
try:
response = self.stepfunctions_client.get_activity_task(
activityArn=activity_arn
)
except ClientError as err:
logger.error(
"Couldn't get a task for activity %s. Here's why: %s: %s",
activity_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
def send_task_success(self, task_token, task_response):
"""
Sends a success response to a waiting activity step. A state machine with an
activity step waits for the activity to get task data and then respond with
either success or failure before it resumes processing.
:param task_token: The token associated with the task. This is included in the
response to the get_activity_task action and must be sent
without modification.
:param task_response: The response data from the activity. This data is
received and processed by the state machine.
"""
try:
self.stepfunctions_client.send_task_success(
taskToken=task_token, output=task_response
)
except ClientError as err:
logger.error(
"Couldn't send task success. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
def delete(self, activity_arn):
"""
Delete an activity.
:param activity_arn: The ARN of the activity to delete.
"""
try:
response = self.stepfunctions_client.delete_activity(
activityArn=activity_arn
)
except ClientError as err:
logger.error(
"Couldn't delete activity %s. Here's why: %s: %s",
activity_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener información sobre la API, consulte los siguientes temas en la *Referencia de la API de AWS SDK para Python (Boto3)*.
+ [CreateActivity](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateActivity)
+ [CreateStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateStateMachine)
+ [DeleteActivity](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteActivity)
+ [DeleteStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteStateMachine)
+ [DescribeExecution](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeExecution)
+ [DescribeStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeStateMachine)
+ [GetActivityTask](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/GetActivityTask)
+ [ListActivities](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListActivities)
+ [ListStateMachines](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListStateMachines)
+ [SendTaskSuccess](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/SendTaskSuccess)
+ [StartExecution](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/StartExecution)
+ [StopExecution](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/StopExecution)
------
# Acciones para Step Functions que utilizan AWS SDKs
Los siguientes ejemplos de código muestran cómo realizar acciones individuales de Step Functions con AWS SDKs. Cada ejemplo incluye un enlace a GitHub, donde puede encontrar instrucciones para configurar y ejecutar el código.
Estos fragmentos llaman a la API de Step Functions y son fragmentos de código de programas más grandes que deben ejecutarse en contexto. Puede ver las acciones en contexto en [Escenarios para el uso de Step Functions AWS SDKs](sfn_code_examples_scenarios.md).
Los siguientes ejemplos incluyen solo las acciones que se utilizan con mayor frecuencia. Para ver una lista completa, consulte la [Referencia de la API de AWS Step Functions](https://docs.aws.amazon.com/step-functions/latest/apireference/Welcome.html).
**Topics**
+ [`CreateActivity`](sfn_example_sfn_CreateActivity_section.md)
+ [`CreateStateMachine`](sfn_example_sfn_CreateStateMachine_section.md)
+ [`DeleteActivity`](sfn_example_sfn_DeleteActivity_section.md)
+ [`DeleteStateMachine`](sfn_example_sfn_DeleteStateMachine_section.md)
+ [`DescribeExecution`](sfn_example_sfn_DescribeExecution_section.md)
+ [`DescribeStateMachine`](sfn_example_sfn_DescribeStateMachine_section.md)
+ [`GetActivityTask`](sfn_example_sfn_GetActivityTask_section.md)
+ [`ListActivities`](sfn_example_sfn_ListActivities_section.md)
+ [`ListExecutions`](sfn_example_sfn_ListExecutions_section.md)
+ [`ListStateMachines`](sfn_example_sfn_ListStateMachines_section.md)
+ [`SendTaskSuccess`](sfn_example_sfn_SendTaskSuccess_section.md)
+ [`StartExecution`](sfn_example_sfn_StartExecution_section.md)
# `CreateActivity`Úselo con un AWS SDK
Los siguientes ejemplos de código muestran cómo utilizar `CreateActivity`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Create a Step Functions activity using the supplied name.
///
/// The name for the new Step Functions activity.
/// The Amazon Resource Name (ARN) for the new activity.
public async Task CreateActivity(string activityName)
{
var response = await _amazonStepFunctions.CreateActivityAsync(new CreateActivityRequest { Name = activityName });
return response.ActivityArn;
}
```
+ Para obtener más información sobre la API, consulta [CreateActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateActivity)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [CreateActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateActivity)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun createActivity(activityName: String): String? {
val activityRequest =
CreateActivityRequest {
name = activityName
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.createActivity(activityRequest)
return response.activityArn
}
}
```
+ Para obtener más información sobre la API, consulta [CreateActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def create(self, name):
"""
Create an activity.
:param name: The name of the activity to create.
:return: The Amazon Resource Name (ARN) of the newly created activity.
"""
try:
response = self.stepfunctions_client.create_activity(name=name)
except ClientError as err:
logger.error(
"Couldn't create activity %s. Here's why: %s: %s",
name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["activityArn"]
```
+ Para obtener más información sobre la API, consulta [CreateActivity](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateActivity)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
DATA(lo_result) = lo_sfn->createactivity(
iv_name = iv_name
).
ov_activity_arn = lo_result->get_activityarn( ).
MESSAGE 'Activity created successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnactivityalrdyex.
MESSAGE 'Activity already exists.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidname.
MESSAGE 'Invalid activity name.' TYPE 'E'.
CATCH /aws1/cx_sfnactivitylimitexcd.
MESSAGE 'Activity limit exceeded.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [CreateActivity](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `CreateStateMachine` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `CreateStateMachine`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Create a Step Functions state machine.
///
/// Name for the new Step Functions state
/// machine.
/// A JSON string that defines the Step Functions
/// state machine.
/// The Amazon Resource Name (ARN) of the role.
///
public async Task CreateStateMachine(string stateMachineName, string definition, string roleArn)
{
var request = new CreateStateMachineRequest
{
Name = stateMachineName,
Definition = definition,
RoleArn = roleArn
};
var response =
await _amazonStepFunctions.CreateStateMachineAsync(request);
return response.StateMachineArn;
}
```
+ Para obtener más información sobre la API, consulta [CreateStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateStateMachine)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [CreateStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateStateMachine)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun createMachine(
roleARNVal: String?,
stateMachineName: String?,
jsonVal: String?,
): String? {
val machineRequest =
CreateStateMachineRequest {
definition = jsonVal
name = stateMachineName
roleArn = roleARNVal
type = StateMachineType.Standard
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.createStateMachine(machineRequest)
return response.stateMachineArn
}
}
```
+ Para obtener más información sobre la API, consulta [CreateStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def create(self, name, definition, role_arn):
"""
Creates a state machine with the specific definition. The state machine assumes
the provided role before it starts a run.
:param name: The name to give the state machine.
:param definition: The Amazon States Language definition of the steps in the
the state machine.
:param role_arn: The Amazon Resource Name (ARN) of the role that is assumed by
Step Functions when the state machine is run.
:return: The ARN of the newly created state machine.
"""
try:
response = self.stepfunctions_client.create_state_machine(
name=name, definition=definition, roleArn=role_arn
)
except ClientError as err:
logger.error(
"Couldn't create state machine %s. Here's why: %s: %s",
name,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["stateMachineArn"]
```
+ Para obtener más información sobre la API, consulta [CreateStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateStateMachine)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
DATA(lo_result) = lo_sfn->createstatemachine(
iv_name = iv_name
iv_definition = iv_definition
iv_rolearn = iv_role_arn
).
ov_state_machine_arn = lo_result->get_statemachinearn( ).
MESSAGE 'State machine created successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnstatemachinealrex.
MESSAGE 'State machine already exists.' TYPE 'E'.
CATCH /aws1/cx_sfninvaliddefinition.
MESSAGE 'Invalid state machine definition.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidname.
MESSAGE 'Invalid state machine name.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid role ARN.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [CreateStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `DeleteActivity` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `DeleteActivity`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Delete a Step Machine activity.
///
/// The Amazon Resource Name (ARN) of
/// the activity.
/// A Boolean value indicating the success of the action.
public async Task DeleteActivity(string activityArn)
{
var response = await _amazonStepFunctions.DeleteActivityAsync(new DeleteActivityRequest { ActivityArn = activityArn });
return response.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
```
+ Para obtener más información sobre la API, consulta [DeleteActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteActivity)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [DeleteActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteActivity)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun deleteActivity(actArn: String?) {
val activityRequest =
DeleteActivityRequest {
activityArn = actArn
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.deleteActivity(activityRequest)
println("You have deleted $actArn")
}
}
```
+ Para obtener más información sobre la API, consulta [DeleteActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def delete(self, activity_arn):
"""
Delete an activity.
:param activity_arn: The ARN of the activity to delete.
"""
try:
response = self.stepfunctions_client.delete_activity(
activityArn=activity_arn
)
except ClientError as err:
logger.error(
"Couldn't delete activity %s. Here's why: %s: %s",
activity_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener más información sobre la API, consulta [DeleteActivity](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteActivity)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
lo_sfn->deleteactivity(
iv_activityarn = iv_activity_arn
).
MESSAGE 'Activity deleted successfully.' TYPE 'I'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid activity ARN.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [DeleteActivity](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `DeleteStateMachine` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `DeleteStateMachine`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Delete a Step Functions state machine.
///
/// The Amazon Resource Name (ARN) of the
/// state machine.
/// A Boolean value indicating the success of the action.
public async Task DeleteStateMachine(string stateMachineArn)
{
var response = await _amazonStepFunctions.DeleteStateMachineAsync(new DeleteStateMachineRequest
{ StateMachineArn = stateMachineArn });
return response.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
```
+ Para obtener más información sobre la API, consulta [DeleteStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteStateMachine)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [DeleteStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteStateMachine)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun deleteMachine(stateMachineArnVal: String?) {
val deleteStateMachineRequest =
DeleteStateMachineRequest {
stateMachineArn = stateMachineArnVal
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.deleteStateMachine(deleteStateMachineRequest)
println("$stateMachineArnVal was successfully deleted.")
}
}
```
+ Para obtener más información sobre la API, consulta [DeleteStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def delete(self, state_machine_arn):
"""
Delete a state machine and all of its run data.
:param state_machine_arn: The ARN of the state machine to delete.
"""
try:
response = self.stepfunctions_client.delete_state_machine(
stateMachineArn=state_machine_arn
)
except ClientError as err:
logger.error(
"Couldn't delete state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener más información sobre la API, consulta [DeleteStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteStateMachine)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
lo_sfn->deletestatemachine(
iv_statemachinearn = iv_state_machine_arn
).
MESSAGE 'State machine deleted successfully.' TYPE 'I'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid state machine ARN.' TYPE 'E'.
CATCH /aws1/cx_sfnvalidationex.
MESSAGE 'Validation error occurred.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [DeleteStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `DescribeExecution` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `DescribeExecution`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Retrieve information about the specified Step Functions execution.
///
/// The Amazon Resource Name (ARN) of the
/// Step Functions execution.
/// The API response returned by the API.
public async Task DescribeExecutionAsync(string executionArn)
{
var response = await _amazonStepFunctions.DescribeExecutionAsync(new DescribeExecutionRequest { ExecutionArn = executionArn });
return response;
}
```
+ Para obtener más información sobre la API, consulta [DescribeExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeExecution)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [DescribeExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeExecution)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun describeExe(executionArnVal: String?) {
val executionRequest =
DescribeExecutionRequest {
executionArn = executionArnVal
}
var status = ""
var hasSucceeded = false
while (!hasSucceeded) {
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.describeExecution(executionRequest)
status = response.status.toString()
if (status.compareTo("Running") == 0) {
println("The state machine is still running, let's wait for it to finish.")
Thread.sleep(2000)
} else if (status.compareTo("Succeeded") == 0) {
println("The Step Function workflow has succeeded")
hasSucceeded = true
} else {
println("The Status is $status")
}
}
}
println("The Status is $status")
}
```
+ Para obtener más información sobre la API, consulta [DescribeExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
def describe_run(self, run_arn):
"""
Get data about a state machine run, such as its current status or final output.
:param run_arn: The ARN of the run to look up.
:return: The retrieved run data.
"""
try:
response = self.stepfunctions_client.describe_execution(
executionArn=run_arn
)
except ClientError as err:
logger.error(
"Couldn't describe run %s. Here's why: %s: %s",
run_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener más información sobre la API, consulta [DescribeExecution](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeExecution)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
oo_result = lo_sfn->describeexecution(
iv_executionarn = iv_execution_arn
).
MESSAGE 'Execution described successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnexecdoesnotexist.
MESSAGE 'Execution does not exist.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid execution ARN.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [DescribeExecution](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `DescribeStateMachine` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `DescribeStateMachine`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Retrieve information about the specified Step Functions state machine.
///
/// The Amazon Resource Name (ARN) of the
/// Step Functions state machine to retrieve.
/// Information about the specified Step Functions state machine.
public async Task DescribeStateMachineAsync(string StateMachineArn)
{
var response = await _amazonStepFunctions.DescribeStateMachineAsync(new DescribeStateMachineRequest { StateMachineArn = StateMachineArn });
return response;
}
```
+ Para obtener más información sobre la API, consulta [DescribeStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeStateMachine)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [DescribeStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeStateMachine)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun describeStateMachine(stateMachineArnVal: String?) {
val stateMachineRequest =
DescribeStateMachineRequest {
stateMachineArn = stateMachineArnVal
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.describeStateMachine(stateMachineRequest)
println("The name of the State machine is ${response.name}")
println("The status of the State machine is ${response.status}")
println("The ARN value of the State machine is ${response.stateMachineArn}")
println("The role ARN value is ${response.roleArn}")
}
}
```
+ Para obtener más información sobre la API, consulta [DescribeStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def describe(self, state_machine_arn):
"""
Get data about a state machine.
:param state_machine_arn: The ARN of the state machine to look up.
:return: The retrieved state machine data.
"""
try:
response = self.stepfunctions_client.describe_state_machine(
stateMachineArn=state_machine_arn
)
except ClientError as err:
logger.error(
"Couldn't describe state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener más información sobre la API, consulta [DescribeStateMachine](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeStateMachine)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
oo_result = lo_sfn->describestatemachine(
iv_statemachinearn = iv_state_machine_arn
).
MESSAGE 'State machine described successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnstatemachinedoes00.
MESSAGE 'State machine does not exist.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid state machine ARN.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [DescribeStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `GetActivityTask` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `GetActivityTask`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Retrieve a task with the specified Step Functions activity
/// with the specified Amazon Resource Name (ARN).
///
/// The Amazon Resource Name (ARN) of
/// the Step Functions activity.
/// The name of the Step Functions worker.
/// The response from the Step Functions activity.
public async Task GetActivityTaskAsync(string activityArn, string workerName)
{
var response = await _amazonStepFunctions.GetActivityTaskAsync(new GetActivityTaskRequest
{ ActivityArn = activityArn, WorkerName = workerName });
return response;
}
```
+ Para obtener más información sobre la API, consulta [GetActivityTask](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/GetActivityTask)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [GetActivityTask](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/GetActivityTask)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun getActivityTask(actArn: String?): List {
val myList: MutableList = ArrayList()
val getActivityTaskRequest =
GetActivityTaskRequest {
activityArn = actArn
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.getActivityTask(getActivityTaskRequest)
myList.add(response.taskToken.toString())
myList.add(response.input.toString())
return myList
}
}
```
+ Para obtener más información sobre la API, consulta [GetActivityTask](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def get_task(self, activity_arn):
"""
Gets task data for an activity. When a state machine is waiting for the
specified activity, a response is returned with data from the state machine.
When a state machine is not waiting, this call blocks for 60 seconds.
:param activity_arn: The ARN of the activity to get task data for.
:return: The task data for the activity.
"""
try:
response = self.stepfunctions_client.get_activity_task(
activityArn=activity_arn
)
except ClientError as err:
logger.error(
"Couldn't get a task for activity %s. Here's why: %s: %s",
activity_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response
```
+ Para obtener más información sobre la API, consulta [GetActivityTask](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/GetActivityTask)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
oo_result = lo_sfn->getactivitytask(
iv_activityarn = iv_activity_arn
).
MESSAGE 'Activity task retrieved successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnactivitydoesnotex.
MESSAGE 'Activity does not exist.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid activity ARN.' TYPE 'E'.
CATCH /aws1/cx_sfnactivityworkerlm00.
MESSAGE 'Activity worker limit exceeded.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [GetActivityTask](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `ListActivities` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `ListActivities`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// List the Step Functions activities for the current account.
///
/// A list of ActivityListItems.
public async Task> ListActivitiesAsync()
{
var request = new ListActivitiesRequest();
var activities = new List();
do
{
var response = await _amazonStepFunctions.ListActivitiesAsync(request);
if (response.NextToken is not null)
{
request.NextToken = response.NextToken;
}
activities.AddRange(response.Activities);
}
while (request.NextToken is not null);
return activities;
}
```
+ Para obtener más información sobre la API, consulta [ListActivities](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListActivities)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [ListActivities](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListActivities)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun listAllActivites() {
val activitiesRequest =
ListActivitiesRequest {
maxResults = 10
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.listActivities(activitiesRequest)
response.activities?.forEach { item ->
println("The activity ARN is ${item.activityArn}")
println("The activity name is ${item.name}")
}
}
}
```
+ Para obtener más información sobre la API, consulta [ListActivities](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def find(self, name):
"""
Find an activity by name. This requires listing activities until one is found
with a matching name.
:param name: The name of the activity to search for.
:return: If found, the ARN of the activity; otherwise, None.
"""
try:
paginator = self.stepfunctions_client.get_paginator("list_activities")
for page in paginator.paginate():
for activity in page.get("activities", []):
if activity["name"] == name:
return activity["activityArn"]
except ClientError as err:
logger.error(
"Couldn't list activities. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
+ Para obtener más información sobre la API, consulta [ListActivities](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListActivities)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
DATA(lo_result) = lo_sfn->listactivities( ).
DATA(lt_activities) = lo_result->get_activities( ).
LOOP AT lt_activities INTO DATA(lo_activity).
IF lo_activity->get_name( ) = iv_name.
ov_activity_arn = lo_activity->get_activityarn( ).
EXIT.
ENDIF.
ENDLOOP.
MESSAGE 'Activities listed successfully.' TYPE 'I'.
CATCH /aws1/cx_sfninvalidtoken.
MESSAGE 'Invalid pagination token.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [ListActivities](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `ListExecutions` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `ListExecutions`.
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Retrieve information about executions of a Step Functions
/// state machine.
///
/// The Amazon Resource Name (ARN) of the
/// Step Functions state machine.
/// A list of ExecutionListItem objects.
public async Task> ListExecutionsAsync(string stateMachineArn)
{
var executions = new List();
ListExecutionsResponse response;
var request = new ListExecutionsRequest { StateMachineArn = stateMachineArn };
do
{
response = await _amazonStepFunctions.ListExecutionsAsync(request);
executions.AddRange(response.Executions);
if (response.NextToken is not null)
{
request.NextToken = response.NextToken;
}
} while (response.NextToken is not null);
return executions;
}
```
+ Para obtener más información sobre la API, consulta [ListExecutions](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListExecutions)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [ListExecutions](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListExecutions)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun getExeHistory(exeARN: String?) {
val historyRequest =
GetExecutionHistoryRequest {
executionArn = exeARN
maxResults = 10
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.getExecutionHistory(historyRequest)
response.events?.forEach { event ->
println("The event type is ${event.type}")
}
}
}
```
+ Para obtener más información sobre la API, consulta [ListExecutions](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
# Úselo `ListStateMachines` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `ListStateMachines`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Retrieve a list of Step Functions state machines.
///
/// A list of StateMachineListItem objects.
public async Task> ListStateMachinesAsync()
{
var stateMachines = new List();
var listStateMachinesPaginator =
_amazonStepFunctions.Paginators.ListStateMachines(new ListStateMachinesRequest());
await foreach (var response in listStateMachinesPaginator.Responses)
{
stateMachines.AddRange(response.StateMachines);
}
return stateMachines;
}
```
+ Para obtener más información sobre la API, consulta [ListStateMachines](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListStateMachines)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
import aws.sdk.kotlin.services.sfn.SfnClient
import aws.sdk.kotlin.services.sfn.model.ListStateMachinesRequest
/**
Before running this Kotlin 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-kotlin/latest/developer-guide/setup.html
*/
suspend fun main() {
println(DASHES)
println("Welcome to the AWS Step Functions Hello example.")
println("Lets list up to ten of your state machines:")
println(DASHES)
listMachines()
}
suspend fun listMachines() {
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.listStateMachines(ListStateMachinesRequest {})
response.stateMachines?.forEach { machine ->
println("The name of the state machine is ${machine.name}")
println("The ARN value is ${machine.stateMachineArn}")
}
}
}
```
+ Para obtener más información sobre la API, consulta [ListStateMachines](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
Busque una máquina de estado por su nombre buscando la cuenta en la lista de máquinas de estado.
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def find(self, name):
"""
Find a state machine by name. This requires listing the state machines until
one is found with a matching name.
:param name: The name of the state machine to search for.
:return: The ARN of the state machine if found; otherwise, None.
"""
try:
paginator = self.stepfunctions_client.get_paginator("list_state_machines")
for page in paginator.paginate():
for state_machine in page.get("stateMachines", []):
if state_machine["name"] == name:
return state_machine["stateMachineArn"]
except ClientError as err:
logger.error(
"Couldn't list state machines. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
+ Para obtener más información sobre la API, consulta [ListStateMachines](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListStateMachines)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
DATA(lo_result) = lo_sfn->liststatemachines( ).
DATA(lt_state_machines) = lo_result->get_statemachines( ).
LOOP AT lt_state_machines INTO DATA(lo_state_machine).
IF lo_state_machine->get_name( ) = iv_name.
ov_state_machine_arn = lo_state_machine->get_statemachinearn( ).
EXIT.
ENDIF.
ENDLOOP.
MESSAGE 'State machines listed successfully.' TYPE 'I'.
CATCH /aws1/cx_sfninvalidtoken.
MESSAGE 'Invalid pagination token.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [ListStateMachines](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `SendTaskSuccess` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `SendTaskSuccess`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Indicate that the Step Functions task, indicated by the
/// task token, has completed successfully.
///
/// Identifies the task.
/// The response received from executing the task.
/// A Boolean value indicating the success of the action.
public async Task SendTaskSuccessAsync(string taskToken, string taskResponse)
{
var response = await _amazonStepFunctions.SendTaskSuccessAsync(new SendTaskSuccessRequest
{ TaskToken = taskToken, Output = taskResponse });
return response.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
```
+ Para obtener más información sobre la API, consulta [SendTaskSuccess](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/SendTaskSuccess)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [SendTaskSuccess](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/SendTaskSuccess)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun sendTaskSuccess(
token: String?,
json: String?,
) {
val successRequest =
SendTaskSuccessRequest {
taskToken = token
output = json
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
sfnClient.sendTaskSuccess(successRequest)
}
}
```
+ Para obtener más información sobre la API, consulta [SendTaskSuccess](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class Activity:
"""Encapsulates Step Function activity actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def send_task_success(self, task_token, task_response):
"""
Sends a success response to a waiting activity step. A state machine with an
activity step waits for the activity to get task data and then respond with
either success or failure before it resumes processing.
:param task_token: The token associated with the task. This is included in the
response to the get_activity_task action and must be sent
without modification.
:param task_response: The response data from the activity. This data is
received and processed by the state machine.
"""
try:
self.stepfunctions_client.send_task_success(
taskToken=task_token, output=task_response
)
except ClientError as err:
logger.error(
"Couldn't send task success. Here's why: %s: %s",
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
```
+ Para obtener más información sobre la API, consulta [SendTaskSuccess](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/SendTaskSuccess)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
lo_sfn->sendtasksuccess(
iv_tasktoken = iv_task_token
iv_output = iv_task_response
).
MESSAGE 'Task success sent successfully.' TYPE 'I'.
CATCH /aws1/cx_sfninvalidtoken.
MESSAGE 'Invalid task token.' TYPE 'E'.
CATCH /aws1/cx_sfntaskdoesnotexist.
MESSAGE 'Task does not exist.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidoutput.
MESSAGE 'Invalid task output.' TYPE 'E'.
CATCH /aws1/cx_sfntasktimedout.
MESSAGE 'Task timed out.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [SendTaskSuccess](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Úselo `StartExecution` con un SDK AWS
Los siguientes ejemplos de código muestran cómo utilizar `StartExecution`.
Los ejemplos de acciones son extractos de código de programas más grandes y deben ejecutarse en contexto. Puede ver esta acción en contexto en el siguiente ejemplo de código:
+ [Conceptos básicos](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK para .NET**
Hay más en marcha GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/dotnetv3/StepFunctions#code-examples).
```
///
/// Start execution of an AWS Step Functions state machine.
///
/// The name to use for the execution.
/// The JSON string to pass for execution.
/// The Amazon Resource Name (ARN) of the
/// Step Functions state machine.
/// The Amazon Resource Name (ARN) of the AWS Step Functions
/// execution.
public async Task StartExecutionAsync(string executionJson, string stateMachineArn)
{
var executionRequest = new StartExecutionRequest
{
Input = executionJson,
StateMachineArn = stateMachineArn
};
var response = await _amazonStepFunctions.StartExecutionAsync(executionRequest);
return response.ExecutionArn;
}
```
+ Para obtener más información sobre la API, consulta [StartExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/StartExecution)la *Referencia AWS SDK para .NET de la API*.
------
#### [ Java ]
**SDK para Java 2.x**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](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 obtener más información sobre la API, consulta [StartExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StartExecution)la *Referencia AWS SDK for Java 2.x de la API*.
------
#### [ JavaScript ]
**SDK para JavaScript (v3)**
Hay más información. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javascriptv3/example_code/sfn#code-examples).
```
import { SFNClient, StartExecutionCommand } from "@aws-sdk/client-sfn";
/**
* @param {{ sfnClient: SFNClient, stateMachineArn: string }} config
*/
export async function startExecution({ sfnClient, stateMachineArn }) {
const response = await sfnClient.send(
new StartExecutionCommand({
stateMachineArn,
}),
);
console.log(response);
// Example response:
// {
// '$metadata': {
// httpStatusCode: 200,
// requestId: '202a9309-c16a-454b-adeb-c4d19afe3bf2',
// extendedRequestId: undefined,
// cfId: undefined,
// attempts: 1,
// totalRetryDelay: 0
// },
// executionArn: 'arn:aws:states:us-east-1:000000000000:execution:MyStateMachine:aaaaaaaa-f787-49fb-a20c-1b61c64eafe6',
// startDate: 2024-01-04T15:54:08.362Z
// }
return response;
}
// Call function if run directly
import { fileURLToPath } from "node:url";
if (process.argv[1] === fileURLToPath(import.meta.url)) {
startExecution({ sfnClient: new SFNClient({}), stateMachineArn: "ARN" });
}
```
+ Para obtener más información sobre la API, consulta [StartExecution](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/sfn/command/StartExecutionCommand)la *Referencia AWS SDK para JavaScript de la API*.
------
#### [ Kotlin ]
**SDK para Kotlin**
Hay más información al respecto GitHub. Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/kotlin/services/stepfunctions#code-examples).
```
suspend fun startWorkflow(
stateMachineArnVal: String?,
jsonEx: String?,
): String? {
val uuid = UUID.randomUUID()
val uuidValue = uuid.toString()
val executionRequest =
StartExecutionRequest {
input = jsonEx
stateMachineArn = stateMachineArnVal
name = uuidValue
}
SfnClient.fromEnvironment { region = "us-east-1" }.use { sfnClient ->
val response = sfnClient.startExecution(executionRequest)
return response.executionArn
}
}
```
+ Para obtener más información sobre la API, consulta [StartExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)la *referencia sobre el AWS SDK para la API de Kotlin*.
------
#### [ Python ]
**SDK para Python (Boto3)**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
```
class StateMachine:
"""Encapsulates Step Functions state machine actions."""
def __init__(self, stepfunctions_client):
"""
:param stepfunctions_client: A Boto3 Step Functions client.
"""
self.stepfunctions_client = stepfunctions_client
def start(self, state_machine_arn, run_input):
"""
Start a run of a state machine with a specified input. A run is also known
as an "execution" in Step Functions.
:param state_machine_arn: The ARN of the state machine to run.
:param run_input: The input to the state machine, in JSON format.
:return: The ARN of the run. This can be used to get information about the run,
including its current status and final output.
"""
try:
response = self.stepfunctions_client.start_execution(
stateMachineArn=state_machine_arn, input=run_input
)
except ClientError as err:
logger.error(
"Couldn't start state machine %s. Here's why: %s: %s",
state_machine_arn,
err.response["Error"]["Code"],
err.response["Error"]["Message"],
)
raise
else:
return response["executionArn"]
```
+ Para obtener más información sobre la API, consulta [StartExecution](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/StartExecution)la *AWS Referencia de API de SDK for Python (Boto3*).
------
#### [ SAP ABAP ]
**SDK para SAP ABAP**
Hay más información al respecto. GitHub Busque el ejemplo completo y aprenda a configurar y ejecutar en el [Repositorio de ejemplos de código de AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/sap-abap/services/sfn#code-examples).
```
TRY.
DATA(lo_result) = lo_sfn->startexecution(
iv_statemachinearn = iv_state_machine_arn
iv_input = iv_input
).
ov_execution_arn = lo_result->get_executionarn( ).
MESSAGE 'Execution started successfully.' TYPE 'I'.
CATCH /aws1/cx_sfnstatemachinedoes00.
MESSAGE 'State machine does not exist.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidarn.
MESSAGE 'Invalid state machine ARN.' TYPE 'E'.
CATCH /aws1/cx_sfninvalidexecinput.
MESSAGE 'Invalid execution input.' TYPE 'E'.
CATCH /aws1/cx_sfnexeclimitexceeded.
MESSAGE 'Execution limit exceeded.' TYPE 'E'.
ENDTRY.
```
+ Para obtener más información sobre la API, consulte [StartExecution](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)la *referencia sobre la API ABAP del AWS SDK para SAP*.
------
# Escenarios para el uso de Step Functions AWS SDKs
Los siguientes ejemplos de código muestran cómo implementar escenarios comunes en Step Functions with AWS SDKs. Estos escenarios muestran cómo realizar tareas específicas con llamadas a varias funciones dentro de Step Functions o en combinación con otros Servicios de AWS. En cada escenario se incluye un enlace al código fuente completo, con instrucciones de configuración y ejecución del código.
Los escenarios requieren un nivel intermedio de experiencia para entender las acciones de servicio en su contexto.
**Topics**
+ [Creación de una aplicación de mensajería](sfn_example_cross_StepFunctionsMessenger_section.md)
+ [Orquestación de aplicaciones de IA generativa con Step Functions](sfn_example_cross_ServerlessPromptChaining_section.md)
+ [Usar Step Functions para invocar funciones de Lambda](sfn_example_cross_ServerlessWorkflows_section.md)
# Creación de una aplicación de mensajería con Step Functions
El siguiente ejemplo de código muestra cómo crear una aplicación de AWS Step Functions mensajería que recupere los registros de mensajes de una tabla de base de datos.
------
#### [ Python ]
**SDK para Python (Boto3)**
Muestra cómo utilizar AWS SDK para Python (Boto3) with AWS Step Functions para crear una aplicación de mensajería que recupere los registros de mensajes de una tabla de Amazon DynamoDB y los envíe con Amazon Simple Queue Service (Amazon SQS). La máquina de estados se integra con una AWS Lambda función para escanear la base de datos en busca de mensajes no enviados.
+ Crear una máquina de estado que recupere y actualice los registros de mensajes de una tabla de Amazon DynamoDB.
+ Actualizar la definición de la máquina de estado para que también envíe mensajes a Amazon Simple Queue Service (Amazon SQS).
+ Iniciar y detener las ejecuciones de la máquina de estado.
+ Conectar con Lambda, DynamoDB y Amazon SQS desde una máquina de estado mediante integraciones de servicio.
Para obtener el código fuente completo y las instrucciones sobre cómo configurarlo y ejecutarlo, consulte el ejemplo completo en [GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/cross_service/stepfunctions_messenger).
**Servicios utilizados en este ejemplo**
+ DynamoDB
+ Lambda
+ Amazon SQS
+ Step Functions
------
# Creación y orquestación de aplicaciones de IA generativa con Amazon Bedrock y Step Functions
En el siguiente ejemplo de código se muestra cómo crear y orquestar aplicaciones de IA generativa mediante Amazon Bedrock y Step Functions.
------
#### [ Python ]
**SDK para Python (Boto3)**
El escenario de encadenamiento de peticiones de Amazon Bedrock sin servidor muestra cómo se puede utilizar [AWS Step Functions](https://docs.aws.amazon.com/step-functions/latest/dg/welcome.html), [Amazon Bedrock](https://docs.aws.amazon.com/bedrock/latest/userguide/what-is-bedrock.html) y [https://docs.aws.amazon.com/bedrock/latest/userguide/agents.html](https://docs.aws.amazon.com/bedrock/latest/userguide/agents.html) para crear y orquestar aplicaciones de IA generativa complejas, sin servidor y altamente escalables. Contiene los siguientes ejemplos prácticos:
+ Escribir un análisis de una novela determinada para un blog de literatura. Este ejemplo ilustra una cadena de peticiones simple y secuencial.
+ Generar una historia corta sobre un tema determinado. Este ejemplo ilustra cómo la IA puede procesar de forma iterativa una lista de elementos generados previamente.
+ Crear un itinerario para una salida de fin de semana a un destino determinado. Este ejemplo ilustra cómo paralelizar varias peticiones distintas.
+ Presentar ideas de películas a un usuario humano que actúe como productor de películas. Este ejemplo ilustra cómo paralelizar la misma petición con diferentes parámetros de inferencia, cómo retroceder a un paso anterior de la cadena y cómo incluir la intervención humana como parte del flujo de trabajo.
+ Planificar una comida en función de los ingredientes que el usuario tenga a mano. Este ejemplo ilustra cómo las cadenas de peticiones pueden incorporar dos conversaciones distintas de IA, en las que dos personas de IA empiezan a debatir para mejorar el resultado final.
+ Encuentre y resuma el GitHub repositorio más popular de la actualidad. Este ejemplo ilustra cómo encadenar varios agentes de IA que interactúan con agentes externos. APIs
Para ver el código fuente completo y las instrucciones de configuración y ejecución, consulta el proyecto completo en [GitHub](https://github.com/aws-samples/amazon-bedrock-serverless-prompt-chaining).
**Servicios utilizados en este ejemplo**
+ Amazon Bedrock
+ Amazon Bedrock Runtime
+ Agentes de Amazon Bedrock
+ Tiempo de ejecución de agentes de Amazon Bedrock
+ Step Functions
------
# Uso de Step Functions para invocar funciones de Lambda
El siguiente ejemplo de código muestra cómo crear una máquina de AWS Step Functions estados que invoque AWS Lambda funciones en secuencia.
------
#### [ Java ]
**SDK para Java 2.x**
Muestra cómo crear un flujo de trabajo AWS sin servidor mediante AWS Step Functions y el. AWS SDK for Java 2.x Cada paso del flujo de trabajo se implementa mediante una AWS Lambda función.
Para obtener el código fuente completo y las instrucciones sobre cómo configurarlo y ejecutarlo, consulte el ejemplo completo en [GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/usecases/creating_workflows_stepfunctions).
**Servicios utilizados en este ejemplo**
+ DynamoDB
+ Lambda
+ Amazon SES
+ Step Functions
------