CfnTelemetryPipelinesPropsMixin Mixin
Creates a telemetry pipeline for processing and transforming telemetry data.
The pipeline defines how data flows from sources through processors to destinations, enabling data transformation and delivering capabilities.
Using CloudWatch as a pipeline source The following is an example of a Body property value for the Configuration object. { "Type": "AWS::ObservabilityAdmin::TelemetryPipelines", "Properties": { "Configuration": { "Body": "pipeline:\n source:\n cloudwatch_logs:\n log_event_metadata:\n data_source_name: "my_data_source"\n data_source_type: "default"\n aws:\n sts_role_arn: "arn:aws:iam::123456789012:role/MyPipelineAccessRole"\n processor:\n - parse_json: {}\n sink:\n - cloudwatch_logs:\n log_group: "@original"" } } } Type: AWS::ObservabilityAdmin::TelemetryPipelines Properties: Configuration: Body: | pipeline: source: cloudwatch_logs: log_event_metadata: data_source_name: "my_data_source" data_source_type: "default" aws: sts_role_arn: "arn:aws:iam::123456789012:role/MyPipelineAccessRole" processor: - parse_json: {} sink: - cloudwatch_logs: log_group: "@original" Using Amazon S3 as a pipeline source The following is an example of a Body property value for the Configuration object. { "Type": "AWS::ObservabilityAdmin::TelemetryPipelines", "Properties": { "Configuration": { "Body": "pipeline:\n source:\n s3:\n sqs:\n visibility_timeout: "PT60S"\n visibility_duplication_protection: true\n maximum_messages: 10\n queue_url: "https://sqs.us-east-1.amazonaws.com/123456789012/my-sqs-queue\"\n notification_type: "sqs"\n codec:\n ndjson: {}\n aws:\n region: "us-east-1"\n sts_role_arn: "arn:aws:iam::123456789012:role/MyAccessRole"\n data_source_name: "crowdstrike_falcon"\n processor:\n - ocsf:\n version: "1.5"\n mapping_version: "1.5.0"\n schema:\n crowdstrike_falcon:\n sink:\n - cloudwatch_logs:\n log_group: "my-log-group"" } } } Type: AWS::ObservabilityAdmin::TelemetryPipelines Properties: Configuration: Body: | pipeline: source: s3: sqs: visibility_timeout: "PT60S" visibility_duplication_protection: true maximum_messages: 10 queue_url: "https://sqs.us-east-1.amazonaws.com/123456789012/my-sqs-queue" notification_type: "sqs" codec: ndjson: {} aws: region: "us-east-1" sts_role_arn: "arn:aws:iam::123456789012:role/MyAccessRole" data_source_name: "crowdstrike_falcon" processor: - ocsf: version: "1.5" mapping_version: "1.5.0" schema: crowdstrike_falcon: sink: - cloudwatch_logs: log_group: "my-log-group"
Initializer
new CfnTelemetryPipelinesPropsMixin(props: CfnTelemetryPipelinesMixinProps, options?: CfnPropertyMixinOptions)
CfnTelemetryPipelinesPropsMixin(props: CfnTelemetryPipelinesMixinProps, options: typing.Optional[CfnPropertyMixinOptions] = None)
new CfnTelemetryPipelinesPropsMixin(CfnTelemetryPipelinesMixinProps props, CfnPropertyMixinOptions options)
new CfnTelemetryPipelinesPropsMixin(CfnTelemetryPipelinesMixinProps props, CfnPropertyMixinOptions? options = null)
NewCfnTelemetryPipelinesPropsMixin(Props CfnTelemetryPipelinesMixinProps, Options CfnPropertyMixinOptions)
Methods
applyTo(construct: IConstruct): voiddef apply_to(self, construct: IConstruct) -> Nonepublic void applyTo(IConstruct construct)public void ApplyTo(IConstruct construct)func ApplyTo(Construct IConstruct)#isMixin(x: any): boolean@staticmethod def is_mixin(x: Any) -> boolpublic static Boolean isMixin(Object x)public static bool IsMixin(object x)func IsMixin(X interface{}) *boolstatic#1 parameter · returns
Parameters
xxxxX— Any object.
Returns: true if x is an object created from a class which extends Mixin.
supports(construct: IConstruct): booleandef supports(self, construct: IConstruct) -> boolpublic Boolean supports(IConstruct construct)public bool Supports(IConstruct construct)func Supports(Construct IConstruct) *bool#