StopExecution(string executionArn)
{
var response =
await _amazonStepFunctions.StopExecutionAsync(new StopExecutionRequest { ExecutionArn = executionArn });
return response.HttpStatusCode == System.Net.HttpStatusCode.OK;
}
}
```
+ Per informazioni dettagliate sull’API, consulta i seguenti argomenti nella *documentazione di riferimento dell’API AWS SDK per .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 per Java 2.x**
C'è dell'altro GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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 "";
}
}
```
+ Per informazioni dettagliate sull'API, consulta i seguenti argomenti nella *documentazione di riferimento dell’API AWS SDK for Java 2.x *.
+ [CreateActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateActivity)
+ [CreateStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateStateMachine)
+ [DeleteActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteActivity)
+ [DeleteStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteStateMachine)
+ [DescribeExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeExecution)
+ [DescribeStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeStateMachine)
+ [GetActivityTask](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/GetActivityTask)
+ [ListActivities](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListActivities)
+ [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)
+ [SendTaskSuccess](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/SendTaskSuccess)
+ [StartExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StartExecution)
+ [StopExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StopExecution)
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è dell'altro GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
}
}
```
+ Per informazioni dettagliate sull’API, consulta i seguenti argomenti nella *documentazione di riferimento dell’API AWS SDK per 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 per Python (Boto3)**
C'è dell'altro GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
Esegui uno scenario interattivo al prompt dei comandi.
```
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.")
```
Definisce una classe per il wrapping delle azioni della macchina a stati.
```
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
```
Definisce una classe per il wrapping le azioni dell’attività.
```
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
```
+ Per informazioni dettagliate sull’API, consulta i seguenti argomenti nella *documentazione di riferimento dell’API AWS SDK per 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)
------
# Azioni per Step Functions utilizzando AWS SDKs
I seguenti esempi di codice mostrano come eseguire singole azioni Step Functions con AWS SDKs. Ogni esempio include un collegamento a GitHub, dove è possibile trovare le istruzioni per la configurazione e l'esecuzione del codice.
Questi estratti chiamano l’API Step Functions e sono estratti di codice da programmi più grandi che devono essere eseguiti in modo contestuale. È possibile visualizzare le azioni nel contesto in [Scenari per l'utilizzo di Step Functions AWS SDKs](sfn_code_examples_scenarios.md).
Gli esempi seguenti includono solo le azioni più comunemente utilizzate. Per un elenco completo, consulta la [documentazione di riferimento dell’API 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)
# Utilizzalo `CreateActivity` con un AWS SDK
Gli esempi di codice seguenti mostrano come utilizzare `CreateActivity`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [CreateActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateActivity)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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 "";
}
```
+ Per i dettagli sull'API, [CreateActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateActivity)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
}
}
```
+ Per i dettagli sull'API, [CreateActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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"]
```
+ Per i dettagli sull'API, consulta [CreateActivity AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateActivity)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [CreateActivity](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `CreateStateMachine` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `CreateStateMachine`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [CreateStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/CreateStateMachine)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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 "";
}
```
+ Per i dettagli sull'API, [CreateStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/CreateStateMachine)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
}
}
```
+ Per i dettagli sull'API, [CreateStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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"]
```
+ Per i dettagli sull'API, consulta [CreateStateMachine AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/CreateStateMachine)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [CreateStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `DeleteActivity` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `DeleteActivity`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [DeleteActivity](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteActivity)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
```
+ Per i dettagli sull'API, [DeleteActivity](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteActivity)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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")
}
}
```
+ Per i dettagli sull'API, [DeleteActivity](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [DeleteActivity AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteActivity)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [DeleteActivity](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `DeleteStateMachine` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `DeleteStateMachine`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [DeleteStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DeleteStateMachine)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.");
}
```
+ Per i dettagli sull'API, [DeleteStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DeleteStateMachine)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.")
}
}
```
+ Per i dettagli sull'API, [DeleteStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [DeleteStateMachine AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DeleteStateMachine)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [DeleteStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `DescribeExecution` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `DescribeExecution`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [DescribeExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeExecution)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
```
+ Per i dettagli sull'API, [DescribeExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeExecution)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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")
}
```
+ Per i dettagli sull'API, [DescribeExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [DescribeExecution AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeExecution)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [DescribeExecution](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `DescribeStateMachine` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `DescribeStateMachine`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [DescribeStateMachine](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/DescribeStateMachine)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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());
}
}
```
+ Per i dettagli sull'API, [DescribeStateMachine](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/DescribeStateMachine)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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}")
}
}
```
+ Per i dettagli sull'API, [DescribeStateMachine](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [DescribeStateMachine AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/DescribeStateMachine)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [DescribeStateMachine](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `GetActivityTask` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `GetActivityTask`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [GetActivityTask](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/GetActivityTask)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [GetActivityTask](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/GetActivityTask)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
}
}
```
+ Per i dettagli sull'API, [GetActivityTask](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [GetActivityTask AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/GetActivityTask)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [GetActivityTask](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `ListActivities` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `ListActivities`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [ListActivities](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListActivities)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
}
```
+ Per i dettagli sull'API, [ListActivities](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListActivities)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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}")
}
}
}
```
+ Per i dettagli sull'API, [ListActivities](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [ListActivities AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListActivities)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [ListActivities](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `ListExecutions` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `ListExecutions`.
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [ListExecutions](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListExecutions)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
```
+ Per i dettagli sull'API, [ListExecutions](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListExecutions)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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}")
}
}
}
```
+ Per i dettagli sull'API, [ListExecutions](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
# Utilizzalo `ListStateMachines` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `ListStateMachines`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [ListStateMachines](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/ListStateMachines)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
}
```
+ Per i dettagli sull'API, [ListStateMachines](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/ListStateMachines)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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}")
}
}
}
```
+ Per i dettagli sull'API, [ListStateMachines](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice AWS](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/example_code/stepfunctions#code-examples).
Per cercare una macchina a stati per nome eseguendo la ricerca dell’account nell’elenco delle macchine a stati.
```
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
```
+ Per i dettagli sull'API, consulta [ListStateMachines AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/ListStateMachines)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [ListStateMachines](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `SendTaskSuccess` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `SendTaskSuccess`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [SendTaskSuccess](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/SendTaskSuccess)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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);
}
}
```
+ Per i dettagli sull'API, [SendTaskSuccess](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/SendTaskSuccess)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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)
}
}
```
+ Per i dettagli sull'API, [SendTaskSuccess](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
```
+ Per i dettagli sull'API, consulta [SendTaskSuccess AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/SendTaskSuccess)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [SendTaskSuccess](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Utilizzare `StartExecution` con un SDK AWS
Gli esempi di codice seguenti mostrano come utilizzare `StartExecution`.
Gli esempi di operazioni sono estratti di codice da programmi più grandi e devono essere eseguiti nel contesto. È possibile visualizzare questa operazione nel contesto nel seguente esempio di codice:
+ [Informazioni di base](sfn_example_sfn_Scenario_GetStartedStateMachines_section.md)
------
#### [ .NET ]
**SDK per .NET**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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;
}
```
+ Per i dettagli sull'API, [StartExecution](https://docs.aws.amazon.com/goto/DotNetSDKV3/states-2016-11-23/StartExecution)consulta *AWS SDK per .NET API Reference*.
------
#### [ Java ]
**SDK per Java 2.x**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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 "";
}
```
+ Per i dettagli sull'API, [StartExecution](https://docs.aws.amazon.com/goto/SdkForJavaV2/states-2016-11-23/StartExecution)consulta *AWS SDK for Java 2.x API Reference*.
------
#### [ JavaScript ]
**SDK per JavaScript (v3)**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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" });
}
```
+ Per i dettagli sull'API, [StartExecution](https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/sfn/command/StartExecutionCommand)consulta *AWS SDK per JavaScript API Reference*.
------
#### [ Kotlin ]
**SDK per Kotlin**
C'è altro su GitHub. Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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
}
}
```
+ Per i dettagli sull'API, [StartExecution](https://sdk.amazonaws.com/kotlin/api/latest/index.html)consulta *AWS SDK for Kotlin* API reference.
------
#### [ Python ]
**SDK per Python (Boto3)**
C'è di più su. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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"]
```
+ Per i dettagli sull'API, consulta [StartExecution AWS](https://docs.aws.amazon.com/goto/boto3/states-2016-11-23/StartExecution)*SDK for Python (Boto3) API Reference*.
------
#### [ SAP ABAP ]
**SDK per SAP ABAP**
C'è altro da fare. GitHub Trova l'esempio completo e scopri di più sulla configurazione e l'esecuzione nel [Repository di esempi di codice 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.
```
+ Per i dettagli sulle API, [StartExecution](https://docs.aws.amazon.com/sdk-for-sap-abap/v1/api/latest/index.html)consulta *AWS SDK for SAP ABAP* API reference.
------
# Scenari per l'utilizzo di Step Functions AWS SDKs
I seguenti esempi di codice mostrano come implementare scenari comuni in Step Functions con AWS SDKs. Questi scenari illustrano come eseguire attività specifiche chiamando più funzioni all’interno di Step Functions o in combinazione con altri Servizi AWS. Ogni scenario include un collegamento al codice sorgente completo, dove è possibile trovare le istruzioni su come configurare ed eseguire il codice.
Gli scenari sono relativi a un livello intermedio di esperienza per aiutarti a comprendere le azioni di servizio nel contesto.
**Topics**
+ [Creazione di un’applicazione di messaggistica](sfn_example_cross_StepFunctionsMessenger_section.md)
+ [Orchestrare applicazioni di IA generativa con Step Functions](sfn_example_cross_ServerlessPromptChaining_section.md)
+ [Utilizzo di Step Functions per invocare le funzioni Lambda](sfn_example_cross_ServerlessWorkflows_section.md)
# Creazione di un’applicazione di messaggistica con Step Functions
Il seguente esempio di codice mostra come creare un'applicazione di AWS Step Functions messaggistica che recupera i record dei messaggi da una tabella di database.
------
#### [ Python ]
**SDK per Python (Boto3)**
Mostra come usare AWS SDK per Python (Boto3) with per creare un'applicazione di messaggistica che AWS Step Functions recupera i record dei messaggi da una tabella Amazon DynamoDB e li invia con Amazon Simple Queue Service (Amazon SQS). La macchina a stati si integra con una AWS Lambda funzione per scansionare il database alla ricerca di messaggi non inviati.
+ Crea una macchina a stati che recuperi e aggiorni i record di messaggi da una tabella Amazon DynamoDB.
+ Aggiorna la definizione della macchina a stati per inviare messaggi anche ad Amazon Simple Queue Service (Amazon SQS).
+ Avvia e arresta l’esecuzione della macchina a stati.
+ Connettiti a Lambda, DynamoDB e Amazon SQS da una macchina a stati utilizzando le integrazioni di servizi.
Per il codice sorgente completo e le istruzioni su come configurarlo ed eseguirlo, vedi l'esempio completo su. [GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/python/cross_service/stepfunctions_messenger)
**Servizi utilizzati in questo esempio**
+ DynamoDB
+ Lambda
+ Amazon SQS
+ Step Functions
------
# Creare e orchestrare applicazioni di IA generativa con Amazon Bedrock e Step Functions
L’esempio di codice seguente mostra come creare e orchestrare applicazioni di IA generativa con Amazon Bedrock e Step Functions.
------
#### [ Python ]
**SDK per Python (Boto3)**
Lo scenario di concatenamento di prompt nell’ambiente serverless di Amazon Bedrock dimostra come [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) e [https://docs.aws.amazon.com/bedrock/latest/userguide/agents.html](https://docs.aws.amazon.com/bedrock/latest/userguide/agents.html) possano essere utilizzati per creare e orchestrare applicazioni di IA generativa complesse, serverless e altamente scalabili. Contiene i seguenti esempi di utilizzo:
+ Scrivere l’analisi di un romanzo specifico in un blog letterario. Questo esempio illustra una catena di prompt semplice e sequenziale.
+ Generare una breve relazione su un determinato argomento. Questo esempio illustra come l’intelligenza artificiale (IA) può elaborare in modo iterativo un elenco di elementi generati in precedenza.
+ Creare un itinerario per un fine settimana in una determinata destinazione. Questo esempio illustra come parallelizzare più prompt distinti.
+ Proporre idee per un film a un utente umano che lavora come produttore cinematografico. Questo esempio illustra come parallelizzare lo stesso prompt con parametri di inferenza diversi, come tornare a una fase precedente della catena e come includere l’input umano nel flusso di lavoro.
+ Pianificare un pasto in base agli ingredienti che l’utente ha a portata di mano. Questo esempio illustra come i concatenamenti di prompt possano incorporare due conversazioni di intelligenza artificiale distinte, con due utenti tipo di intelligenza artificiale coinvolti in un dibattito per migliorare il risultato finale.
+ Trova e riepiloga l'archivio con le tendenze GitHub più frequenti di oggi. Questo esempio illustra il concatenamento di più agenti AI che interagiscono con agenti esterni. APIs
Per il codice sorgente completo e le istruzioni per la configurazione e l'esecuzione, consulta il progetto completo su. [GitHub](https://github.com/aws-samples/amazon-bedrock-serverless-prompt-chaining)
**Servizi utilizzati in questo esempio**
+ Amazon Bedrock
+ API Runtime per Amazon Bedrock
+ Agent per Amazon Bedrock
+ API Runtime per Agent per Amazon Bedrock
+ Step Functions
------
# Utilizzo di Step Functions per invocare le funzioni Lambda
Il seguente esempio di codice mostra come creare una macchina a AWS Step Functions stati che richiama AWS Lambda funzioni in sequenza.
------
#### [ Java ]
**SDK per Java 2.x**
Mostra come creare un flusso di lavoro AWS senza server utilizzando AWS Step Functions and. AWS SDK for Java 2.x Ogni fase del flusso di lavoro viene implementata utilizzando una AWS Lambda funzione.
Per il codice sorgente completo e le istruzioni su come configurarlo ed eseguirlo, vedi l'esempio completo su [GitHub](https://github.com/awsdocs/aws-doc-sdk-examples/tree/main/javav2/usecases/creating_workflows_stepfunctions).
**Servizi utilizzati in questo esempio**
+ DynamoDB
+ Lambda
+ Amazon SES
+ Step Functions
------