Interface CfnFlowProps
- All Superinterfaces:
software.amazon.jsii.JsiiSerializable
- All Known Implementing Classes:
CfnFlowProps.Jsii$Proxy
@Generated(value="jsii-pacmak/1.104.0 (build e79254c)",
date="2024-11-21T06:34:03.057Z")
@Stability(Stable)
public interface CfnFlowProps
extends software.amazon.jsii.JsiiSerializable
Properties for defining a
CfnFlow
.
Example:
// The code below shows an example of how to instantiate this type. // The values are placeholders you should change. import software.amazon.awscdk.services.appflow.*; CfnFlowProps cfnFlowProps = CfnFlowProps.builder() .destinationFlowConfigList(List.of(DestinationFlowConfigProperty.builder() .connectorType("connectorType") .destinationConnectorProperties(DestinationConnectorPropertiesProperty.builder() .customConnector(CustomConnectorDestinationPropertiesProperty.builder() .entityName("entityName") // the properties below are optional .customProperties(Map.of( "customPropertiesKey", "customProperties")) .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .idFieldNames(List.of("idFieldNames")) .writeOperationType("writeOperationType") .build()) .eventBridge(EventBridgeDestinationPropertiesProperty.builder() .object("object") // the properties below are optional .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .build()) .lookoutMetrics(LookoutMetricsDestinationPropertiesProperty.builder() .object("object") .build()) .marketo(MarketoDestinationPropertiesProperty.builder() .object("object") // the properties below are optional .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .build()) .redshift(RedshiftDestinationPropertiesProperty.builder() .intermediateBucketName("intermediateBucketName") .object("object") // the properties below are optional .bucketPrefix("bucketPrefix") .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .build()) .s3(S3DestinationPropertiesProperty.builder() .bucketName("bucketName") // the properties below are optional .bucketPrefix("bucketPrefix") .s3OutputFormatConfig(S3OutputFormatConfigProperty.builder() .aggregationConfig(AggregationConfigProperty.builder() .aggregationType("aggregationType") .targetFileSize(123) .build()) .fileType("fileType") .prefixConfig(PrefixConfigProperty.builder() .pathPrefixHierarchy(List.of("pathPrefixHierarchy")) .prefixFormat("prefixFormat") .prefixType("prefixType") .build()) .preserveSourceDataTyping(false) .build()) .build()) .salesforce(SalesforceDestinationPropertiesProperty.builder() .object("object") // the properties below are optional .dataTransferApi("dataTransferApi") .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .idFieldNames(List.of("idFieldNames")) .writeOperationType("writeOperationType") .build()) .sapoData(SAPODataDestinationPropertiesProperty.builder() .objectPath("objectPath") // the properties below are optional .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .idFieldNames(List.of("idFieldNames")) .successResponseHandlingConfig(SuccessResponseHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .build()) .writeOperationType("writeOperationType") .build()) .snowflake(SnowflakeDestinationPropertiesProperty.builder() .intermediateBucketName("intermediateBucketName") .object("object") // the properties below are optional .bucketPrefix("bucketPrefix") .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .build()) .upsolver(UpsolverDestinationPropertiesProperty.builder() .bucketName("bucketName") .s3OutputFormatConfig(UpsolverS3OutputFormatConfigProperty.builder() .prefixConfig(PrefixConfigProperty.builder() .pathPrefixHierarchy(List.of("pathPrefixHierarchy")) .prefixFormat("prefixFormat") .prefixType("prefixType") .build()) // the properties below are optional .aggregationConfig(AggregationConfigProperty.builder() .aggregationType("aggregationType") .targetFileSize(123) .build()) .fileType("fileType") .build()) // the properties below are optional .bucketPrefix("bucketPrefix") .build()) .zendesk(ZendeskDestinationPropertiesProperty.builder() .object("object") // the properties below are optional .errorHandlingConfig(ErrorHandlingConfigProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") .failOnFirstError(false) .build()) .idFieldNames(List.of("idFieldNames")) .writeOperationType("writeOperationType") .build()) .build()) // the properties below are optional .apiVersion("apiVersion") .connectorProfileName("connectorProfileName") .build())) .flowName("flowName") .sourceFlowConfig(SourceFlowConfigProperty.builder() .connectorType("connectorType") .sourceConnectorProperties(SourceConnectorPropertiesProperty.builder() .amplitude(AmplitudeSourcePropertiesProperty.builder() .object("object") .build()) .customConnector(CustomConnectorSourcePropertiesProperty.builder() .entityName("entityName") // the properties below are optional .customProperties(Map.of( "customPropertiesKey", "customProperties")) .dataTransferApi(DataTransferApiProperty.builder() .name("name") .type("type") .build()) .build()) .datadog(DatadogSourcePropertiesProperty.builder() .object("object") .build()) .dynatrace(DynatraceSourcePropertiesProperty.builder() .object("object") .build()) .googleAnalytics(GoogleAnalyticsSourcePropertiesProperty.builder() .object("object") .build()) .inforNexus(InforNexusSourcePropertiesProperty.builder() .object("object") .build()) .marketo(MarketoSourcePropertiesProperty.builder() .object("object") .build()) .pardot(PardotSourcePropertiesProperty.builder() .object("object") .build()) .s3(S3SourcePropertiesProperty.builder() .bucketName("bucketName") .bucketPrefix("bucketPrefix") // the properties below are optional .s3InputFormatConfig(S3InputFormatConfigProperty.builder() .s3InputFileType("s3InputFileType") .build()) .build()) .salesforce(SalesforceSourcePropertiesProperty.builder() .object("object") // the properties below are optional .dataTransferApi("dataTransferApi") .enableDynamicFieldUpdate(false) .includeDeletedRecords(false) .build()) .sapoData(SAPODataSourcePropertiesProperty.builder() .objectPath("objectPath") // the properties below are optional .paginationConfig(SAPODataPaginationConfigProperty.builder() .maxPageSize(123) .build()) .parallelismConfig(SAPODataParallelismConfigProperty.builder() .maxParallelism(123) .build()) .build()) .serviceNow(ServiceNowSourcePropertiesProperty.builder() .object("object") .build()) .singular(SingularSourcePropertiesProperty.builder() .object("object") .build()) .slack(SlackSourcePropertiesProperty.builder() .object("object") .build()) .trendmicro(TrendmicroSourcePropertiesProperty.builder() .object("object") .build()) .veeva(VeevaSourcePropertiesProperty.builder() .object("object") // the properties below are optional .documentType("documentType") .includeAllVersions(false) .includeRenditions(false) .includeSourceFiles(false) .build()) .zendesk(ZendeskSourcePropertiesProperty.builder() .object("object") .build()) .build()) // the properties below are optional .apiVersion("apiVersion") .connectorProfileName("connectorProfileName") .incrementalPullConfig(IncrementalPullConfigProperty.builder() .datetimeTypeFieldName("datetimeTypeFieldName") .build()) .build()) .tasks(List.of(TaskProperty.builder() .sourceFields(List.of("sourceFields")) .taskType("taskType") // the properties below are optional .connectorOperator(ConnectorOperatorProperty.builder() .amplitude("amplitude") .customConnector("customConnector") .datadog("datadog") .dynatrace("dynatrace") .googleAnalytics("googleAnalytics") .inforNexus("inforNexus") .marketo("marketo") .pardot("pardot") .s3("s3") .salesforce("salesforce") .sapoData("sapoData") .serviceNow("serviceNow") .singular("singular") .slack("slack") .trendmicro("trendmicro") .veeva("veeva") .zendesk("zendesk") .build()) .destinationField("destinationField") .taskProperties(List.of(TaskPropertiesObjectProperty.builder() .key("key") .value("value") .build())) .build())) .triggerConfig(TriggerConfigProperty.builder() .triggerType("triggerType") // the properties below are optional .triggerProperties(ScheduledTriggerPropertiesProperty.builder() .scheduleExpression("scheduleExpression") // the properties below are optional .dataPullMode("dataPullMode") .firstExecutionFrom(123) .flowErrorDeactivationThreshold(123) .scheduleEndTime(123) .scheduleOffset(123) .scheduleStartTime(123) .timeZone("timeZone") .build()) .build()) // the properties below are optional .description("description") .flowStatus("flowStatus") .kmsArn("kmsArn") .metadataCatalogConfig(MetadataCatalogConfigProperty.builder() .glueDataCatalog(GlueDataCatalogProperty.builder() .databaseName("databaseName") .roleArn("roleArn") .tablePrefix("tablePrefix") .build()) .build()) .tags(List.of(CfnTag.builder() .key("key") .value("value") .build())) .build();
- See Also:
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic final class
A builder forCfnFlowProps
static final class
An implementation forCfnFlowProps
-
Method Summary
Modifier and TypeMethodDescriptionstatic CfnFlowProps.Builder
builder()
default String
A user-entered description of the flow.The configuration that controls how Amazon AppFlow places data in the destination connector.The specified name of the flow.default String
Sets the status of the flow.default String
The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption.default Object
Specifies the configuration that Amazon AppFlow uses when it catalogs your data.Contains information about the configuration of the source connector used in the flow.getTags()
The tags used to organize, track, or control access for your flow.getTasks()
A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.The trigger settings that determine how and when Amazon AppFlow runs the specified flow.Methods inherited from interface software.amazon.jsii.JsiiSerializable
$jsii$toJson
-
Method Details
-
getDestinationFlowConfigList
The configuration that controls how Amazon AppFlow places data in the destination connector.- See Also:
-
getFlowName
The specified name of the flow.Spaces are not allowed. Use underscores (_) or hyphens (-) only.
- See Also:
-
getSourceFlowConfig
Contains information about the configuration of the source connector used in the flow.- See Also:
-
getTasks
A list of tasks that Amazon AppFlow performs while transferring the data in the flow run.- See Also:
-
getTriggerConfig
The trigger settings that determine how and when Amazon AppFlow runs the specified flow.- See Also:
-
getDescription
A user-entered description of the flow.- See Also:
-
getFlowStatus
Sets the status of the flow. You can specify one of the following values:.- Active - The flow runs based on the trigger settings that you defined. Active scheduled flows run as scheduled, and active event-triggered flows run when the specified change event occurs. However, active on-demand flows run only when you manually start them by using Amazon AppFlow.
- Suspended - You can use this option to deactivate an active flow. Scheduled and event-triggered flows will cease to run until you reactive them. This value only affects scheduled and event-triggered flows. It has no effect for on-demand flows.
If you omit the FlowStatus parameter, Amazon AppFlow creates the flow with a default status. The default status for on-demand flows is Active. The default status for scheduled and event-triggered flows is Draft, which means they’re not yet active.
- See Also:
-
getKmsArn
The ARN (Amazon Resource Name) of the Key Management Service (KMS) key you provide for encryption.This is required if you do not want to use the Amazon AppFlow-managed KMS key. If you don't provide anything here, Amazon AppFlow uses the Amazon AppFlow-managed KMS key.
- See Also:
-
getMetadataCatalogConfig
Specifies the configuration that Amazon AppFlow uses when it catalogs your data.When Amazon AppFlow catalogs your data, it stores metadata in a data catalog.
- See Also:
-
getTags
The tags used to organize, track, or control access for your flow.- See Also:
-
builder
- Returns:
- a
CfnFlowProps.Builder
ofCfnFlowProps
-