/*******************************************************************************
* Copyright 2012-2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
* Licensed under the Apache License, Version 2.0 (the "License"). You may not use
* this file except in compliance with the License. A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file.
* This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
* *****************************************************************************
*
* AWS Tools for Windows (TM) PowerShell (TM)
*
*/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Management.Automation;
using System.Text;
using Amazon.PowerShell.Common;
using Amazon.Runtime;
using Amazon.StepFunctions;
using Amazon.StepFunctions.Model;
namespace Amazon.PowerShell.Cmdlets.SFN
{
///
/// Starts a state machine execution.
///
///
///
/// A qualified state machine ARN can either refer to a Distributed Map state defined
/// within a state machine, a version ARN, or an alias ARN.
///
/// The following are some examples of qualified and unqualified state machine ARNs:
/// -
/// The following qualified state machine ARN refers to a Distributed Map state
/// with a label
mapStateLabel
in a state machine named myStateMachine
.
/// arn:partition:states:region:account-id:stateMachine:myStateMachine/mapStateLabel
/// If you provide a qualified state machine ARN that refers to a Distributed Map state,
/// the request fails with ValidationException
.
/// -
/// The following qualified state machine ARN refers to an alias named
PROD
.
/// arn:<partition>:states:<region>:<account-id>:stateMachine:<myStateMachine:PROD>
/// If you provide a qualified state machine ARN that refers to a version ARN or an alias
/// ARN, the request starts execution for that version or alias.
/// -
/// The following unqualified state machine ARN refers to a state machine named
myStateMachine
.
/// arn:<partition>:states:<region>:<account-id>:stateMachine:<myStateMachine>
/// If you start an execution with an unqualified state machine ARN, Step Functions uses
/// the latest revision of the state machine for the execution.
///
/// To start executions of a state machine version,
/// call StartExecution
and provide the version ARN or the ARN of an alias
/// that points to the version.
/// StartExecution
is idempotent for STANDARD
workflows. For
/// a STANDARD
workflow, if you call StartExecution
with the
/// same name and input as a running execution, the call succeeds and return the same
/// response as the original request. If the execution is closed or if the input is different,
/// it returns a 400 ExecutionAlreadyExists
error. You can reuse names after
/// 90 days.
/// StartExecution
isn't idempotent for EXPRESS
workflows.
///
///
///
[Cmdlet("Start", "SFNExecution", SupportsShouldProcess = true, ConfirmImpact = ConfirmImpact.Medium)]
[OutputType("Amazon.StepFunctions.Model.StartExecutionResponse")]
[AWSCmdlet("Calls the AWS Step Functions StartExecution API operation.", Operation = new[] {"StartExecution"}, SelectReturnType = typeof(Amazon.StepFunctions.Model.StartExecutionResponse))]
[AWSCmdletOutput("Amazon.StepFunctions.Model.StartExecutionResponse",
"This cmdlet returns an Amazon.StepFunctions.Model.StartExecutionResponse object containing multiple properties. The object can also be referenced from properties attached to the cmdlet entry in the $AWSHistory stack."
)]
public partial class StartSFNExecutionCmdlet : AmazonStepFunctionsClientCmdlet, IExecutor
{
protected override bool IsSensitiveRequest { get; set; } = true;
#region Parameter Input
///
///
/// The string that contains the JSON input data for the execution, for example:"input": "{\"first_name\" : \"test\"}"
If you don't include any JSON input data, you still must include the two braces, for
/// example: "input": "{}"
Length constraints apply to the payload size, and are expressed as bytes in UTF-8
/// encoding.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String Input { get; set; }
#endregion
#region Parameter Name
///
///
/// Optional name of the execution. This name must be unique for your Amazon Web Services
/// account, Region, and state machine for 90 days. For more information, see
/// Limits Related to State Machine Executions in the Step Functions Developer
/// Guide.A name must not contain:- white space
- brackets
< > { } [ ]
- wildcard characters
? *
- special characters
" # % \ ^ | ~ ` $ & , ; : /
- control characters (
U+0000-001F
, U+007F-009F
)
To enable logging with CloudWatch Logs, the name should only contain 0-9, A-Z, a-z,
/// - and _.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String Name { get; set; }
#endregion
#region Parameter StateMachineArn
///
///
/// The Amazon Resource Name (ARN) of the state machine to execute.The stateMachineArn
parameter accepts one of the following inputs:- An unqualified state machine ARN – Refers to a state machine ARN that isn't
/// qualified with a version or alias ARN. The following is an example of an unqualified
/// state machine ARN.
arn:<partition>:states:<region>:<account-id>:stateMachine:<myStateMachine>
Step Functions doesn't associate state machine executions that you start with an unqualified
/// ARN with a version. This is true even if that version uses the same revision that
/// the execution used. - A state machine version ARN – Refers to a version ARN, which is a combination
/// of state machine ARN and the version number separated by a colon (:). The following
/// is an example of the ARN for version 10.
arn:<partition>:states:<region>:<account-id>:stateMachine:<myStateMachine>:10
Step Functions doesn't associate executions that you start with a version ARN with
/// any aliases that point to that version. - A state machine alias ARN – Refers to an alias ARN, which is a combination
/// of state machine ARN and the alias name separated by a colon (:). The following is
/// an example of the ARN for an alias named
PROD
.arn:<partition>:states:<region>:<account-id>:stateMachine:<myStateMachine:PROD>
Step Functions associates executions that you start with an alias ARN with that alias
/// and the state machine version used for that execution.
///
///
#if !MODULAR
[System.Management.Automation.Parameter(Position = 0, ValueFromPipelineByPropertyName = true, ValueFromPipeline = true)]
#else
[System.Management.Automation.Parameter(Position = 0, ValueFromPipelineByPropertyName = true, ValueFromPipeline = true, Mandatory = true)]
[System.Management.Automation.AllowEmptyString]
[System.Management.Automation.AllowNull]
#endif
[Amazon.PowerShell.Common.AWSRequiredParameter]
public System.String StateMachineArn { get; set; }
#endregion
#region Parameter TraceHeader
///
///
/// Passes the X-Ray trace header. The trace header can also be passed in the request
/// payload.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String TraceHeader { get; set; }
#endregion
#region Parameter Select
///
/// Use the -Select parameter to control the cmdlet output. The default value is '*'.
/// Specifying -Select '*' will result in the cmdlet returning the whole service response (Amazon.StepFunctions.Model.StartExecutionResponse).
/// Specifying the name of a property of type Amazon.StepFunctions.Model.StartExecutionResponse will result in that property being returned.
/// Specifying -Select '^ParameterName' will result in the cmdlet returning the selected cmdlet parameter value.
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public string Select { get; set; } = "*";
#endregion
#region Parameter PassThru
///
/// Changes the cmdlet behavior to return the value passed to the StateMachineArn parameter.
/// The -PassThru parameter is deprecated, use -Select '^StateMachineArn' instead. This parameter will be removed in a future version.
///
[System.Obsolete("The -PassThru parameter is deprecated, use -Select '^StateMachineArn' instead. This parameter will be removed in a future version.")]
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public SwitchParameter PassThru { get; set; }
#endregion
#region Parameter Force
///
/// This parameter overrides confirmation prompts to force
/// the cmdlet to continue its operation. This parameter should always
/// be used with caution.
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public SwitchParameter Force { get; set; }
#endregion
protected override void ProcessRecord()
{
this._AWSSignerType = "v4";
base.ProcessRecord();
var resourceIdentifiersText = FormatParameterValuesForConfirmationMsg(nameof(this.StateMachineArn), MyInvocation.BoundParameters);
if (!ConfirmShouldProceed(this.Force.IsPresent, resourceIdentifiersText, "Start-SFNExecution (StartExecution)"))
{
return;
}
var context = new CmdletContext();
// allow for manipulation of parameters prior to loading into context
PreExecutionContextLoad(context);
#pragma warning disable CS0618, CS0612 //A class member was marked with the Obsolete attribute
if (ParameterWasBound(nameof(this.Select)))
{
context.Select = CreateSelectDelegate(Select) ??
throw new System.ArgumentException("Invalid value for -Select parameter.", nameof(this.Select));
if (this.PassThru.IsPresent)
{
throw new System.ArgumentException("-PassThru cannot be used when -Select is specified.", nameof(this.Select));
}
}
else if (this.PassThru.IsPresent)
{
context.Select = (response, cmdlet) => this.StateMachineArn;
}
#pragma warning restore CS0618, CS0612 //A class member was marked with the Obsolete attribute
context.Input = this.Input;
context.Name = this.Name;
context.StateMachineArn = this.StateMachineArn;
#if MODULAR
if (this.StateMachineArn == null && ParameterWasBound(nameof(this.StateMachineArn)))
{
WriteWarning("You are passing $null as a value for parameter StateMachineArn which is marked as required. In case you believe this parameter was incorrectly marked as required, report this by opening an issue at https://github.com/aws/aws-tools-for-powershell/issues.");
}
#endif
context.TraceHeader = this.TraceHeader;
// allow further manipulation of loaded context prior to processing
PostExecutionContextLoad(context);
var output = Execute(context) as CmdletOutput;
ProcessOutput(output);
}
#region IExecutor Members
public object Execute(ExecutorContext context)
{
var cmdletContext = context as CmdletContext;
// create request
var request = new Amazon.StepFunctions.Model.StartExecutionRequest();
if (cmdletContext.Input != null)
{
request.Input = cmdletContext.Input;
}
if (cmdletContext.Name != null)
{
request.Name = cmdletContext.Name;
}
if (cmdletContext.StateMachineArn != null)
{
request.StateMachineArn = cmdletContext.StateMachineArn;
}
if (cmdletContext.TraceHeader != null)
{
request.TraceHeader = cmdletContext.TraceHeader;
}
CmdletOutput output;
// issue call
var client = Client ?? CreateClient(_CurrentCredentials, _RegionEndpoint);
try
{
var response = CallAWSServiceOperation(client, request);
object pipelineOutput = null;
pipelineOutput = cmdletContext.Select(response, this);
output = new CmdletOutput
{
PipelineOutput = pipelineOutput,
ServiceResponse = response
};
}
catch (Exception e)
{
output = new CmdletOutput { ErrorResponse = e };
}
return output;
}
public ExecutorContext CreateContext()
{
return new CmdletContext();
}
#endregion
#region AWS Service Operation Call
private Amazon.StepFunctions.Model.StartExecutionResponse CallAWSServiceOperation(IAmazonStepFunctions client, Amazon.StepFunctions.Model.StartExecutionRequest request)
{
Utils.Common.WriteVerboseEndpointMessage(this, client.Config, "AWS Step Functions", "StartExecution");
try
{
#if DESKTOP
return client.StartExecution(request);
#elif CORECLR
return client.StartExecutionAsync(request).GetAwaiter().GetResult();
#else
#error "Unknown build edition"
#endif
}
catch (AmazonServiceException exc)
{
var webException = exc.InnerException as System.Net.WebException;
if (webException != null)
{
throw new Exception(Utils.Common.FormatNameResolutionFailureMessage(client.Config, webException.Message), webException);
}
throw;
}
}
#endregion
internal partial class CmdletContext : ExecutorContext
{
public System.String Input { get; set; }
public System.String Name { get; set; }
public System.String StateMachineArn { get; set; }
public System.String TraceHeader { get; set; }
public System.Func Select { get; set; } =
(response, cmdlet) => response;
}
}
}