Add log autosubscription tag filters config to aws v2 API (#824)

Co-authored-by: ci.datadog-api-spec <[email protected]>

Author: api-clients-generation-pipeline[bot]

.generated-info

@@ -1,4 +1,4 @@
 {
-  "spec_repo_commit": "fd3370f",
-  "generated": "2025-08-06 20:59:11.792"
+  "spec_repo_commit": "c5cca50",
+  "generated": "2025-08-07 18:08:43.875"
 }

.generator/schemas/v2/openapi.yaml

@@ -1625,6 +1625,8 @@ components:
             example: arn:aws:lambda:us-east-1:123456789012:function:DatadogLambdaLogForwarder
             type: string
           type: array
+        log_source_config:
+          $ref: '#/components/schemas/AWSLambdaForwarderConfigLogSourceConfig'
         sources:
           description: 'List of service IDs set to enable automatic log collection.
             Discover the list of available services with the
@@ -1636,6 +1638,44 @@ components:
             type: string
           type: array
       type: object
+    AWSLambdaForwarderConfigLogSourceConfig:
+      description: Log source configuration.
+      properties:
+        tag_filters:
+          description: List of AWS log source tag filters. Defaults to `[]`.
+          items:
+            $ref: '#/components/schemas/AWSLogSourceTagFilter'
+          type: array
+      type: object
+    AWSLogSourceTagFilter:
+      description: 'AWS log source tag filter list. Defaults to `[]`.
+
+        Array of log source to AWS resource tag mappings. Each mapping contains a
+        log source and its associated AWS resource tags (in `key:value` format) used
+        to filter logs submitted to Datadog.
+
+        Tag filters are applied for tags on the AWS resource emitting logs; tags associated
+        with the log storage entity (such as a CloudWatch Log Group or S3 Bucket)
+        are not considered.
+
+        For more information on resource tag filter syntax, [see AWS resource exclusion](https://docs.datadoghq.com/account_management/billing/aws/#aws-resource-exclusion)
+        in the AWS integration billing page.'
+      properties:
+        source:
+          description: The AWS log source to which the tag filters defined in `tags`
+            are applied.
+          example: s3
+          type: string
+        tags:
+          description: The AWS resource tags to filter on for the log source specified
+            by `source`.
+          items:
+            description: Tag in the form `key:value`.
+            example: env:prod
+            type: string
+          nullable: true
+          type: array
+      type: object
     AWSLogsConfig:
       description: AWS Logs Collection config.
       properties:

examples/v2_aws-integration_CreateAWSAccount.rs

@@ -9,6 +9,8 @@ use datadog_api_client::datadogV2::model::AWSAccountType;
 use datadog_api_client::datadogV2::model::AWSAuthConfig;
 use datadog_api_client::datadogV2::model::AWSAuthConfigKeys;
 use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfig;
+use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig;
+use datadog_api_client::datadogV2::model::AWSLogSourceTagFilter;
 use datadog_api_client::datadogV2::model::AWSLogsConfig;
 use datadog_api_client::datadogV2::model::AWSMetricsConfig;
 use datadog_api_client::datadogV2::model::AWSNamespaceTagFilter;
@@ -34,6 +36,13 @@ async fn main() {
                         "arn:aws:lambda:us-east-1:123456789012:function:DatadogLambdaLogForwarder"
                             .to_string(),
                     ])
+                    .log_source_config(AWSLambdaForwarderConfigLogSourceConfig::new().tag_filters(
+                        vec![
+                                            AWSLogSourceTagFilter::new()
+                                                .source("s3".to_string())
+                                                .tags(Some(vec!["test:test".to_string()]))
+                                        ],
+                    ))
                     .sources(vec!["s3".to_string()]),
             ),
         )

examples/v2_aws-integration_CreateAWSAccount_1716720881.rs

@@ -9,6 +9,8 @@ use datadog_api_client::datadogV2::model::AWSAccountType;
 use datadog_api_client::datadogV2::model::AWSAuthConfig;
 use datadog_api_client::datadogV2::model::AWSAuthConfigRole;
 use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfig;
+use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig;
+use datadog_api_client::datadogV2::model::AWSLogSourceTagFilter;
 use datadog_api_client::datadogV2::model::AWSLogsConfig;
 use datadog_api_client::datadogV2::model::AWSMetricsConfig;
 use datadog_api_client::datadogV2::model::AWSNamespaceTagFilter;
@@ -33,6 +35,13 @@ async fn main() {
                         "arn:aws:lambda:us-east-1:123456789012:function:DatadogLambdaLogForwarder"
                             .to_string(),
                     ])
+                    .log_source_config(AWSLambdaForwarderConfigLogSourceConfig::new().tag_filters(
+                        vec![
+                                            AWSLogSourceTagFilter::new()
+                                                .source("s3".to_string())
+                                                .tags(Some(vec!["test:test".to_string()]))
+                                        ],
+                    ))
                     .sources(vec!["s3".to_string()]),
             ),
         )

examples/v2_aws-integration_UpdateAWSAccount.rs

@@ -9,6 +9,8 @@ use datadog_api_client::datadogV2::model::AWSAccountUpdateRequestData;
 use datadog_api_client::datadogV2::model::AWSAuthConfig;
 use datadog_api_client::datadogV2::model::AWSAuthConfigRole;
 use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfig;
+use datadog_api_client::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig;
+use datadog_api_client::datadogV2::model::AWSLogSourceTagFilter;
 use datadog_api_client::datadogV2::model::AWSLogsConfig;
 use datadog_api_client::datadogV2::model::AWSMetricsConfig;
 use datadog_api_client::datadogV2::model::AWSNamespaceTagFilter;
@@ -39,6 +41,16 @@ async fn main() {
                                         "arn:aws:lambda:us-east-1:123456789012:function:DatadogLambdaLogForwarder".to_string()
                                     ],
                                 )
+                                .log_source_config(
+                                    AWSLambdaForwarderConfigLogSourceConfig
+                                    ::new().tag_filters(
+                                        vec![
+                                            AWSLogSourceTagFilter::new()
+                                                .source("s3".to_string())
+                                                .tags(Some(vec!["test:test".to_string()]))
+                                        ],
+                                    ),
+                                )
                                 .sources(vec!["s3".to_string()]),
                         ),
                     )

src/datadogV2/model/mod.rs

@@ -2284,6 +2284,10 @@ pub mod model_aws_logs_config;
 pub use self::model_aws_logs_config::AWSLogsConfig;
 pub mod model_aws_lambda_forwarder_config;
 pub use self::model_aws_lambda_forwarder_config::AWSLambdaForwarderConfig;
+pub mod model_aws_lambda_forwarder_config_log_source_config;
+pub use self::model_aws_lambda_forwarder_config_log_source_config::AWSLambdaForwarderConfigLogSourceConfig;
+pub mod model_aws_log_source_tag_filter;
+pub use self::model_aws_log_source_tag_filter::AWSLogSourceTagFilter;
 pub mod model_aws_metrics_config;
 pub use self::model_aws_metrics_config::AWSMetricsConfig;
 pub mod model_aws_namespace_filters_exclude_only;

src/datadogV2/model/model_aws_lambda_forwarder_config.rs

@@ -15,6 +15,9 @@ pub struct AWSLambdaForwarderConfig {
     /// List of Datadog Lambda Log Forwarder ARNs in your AWS account. Defaults to `[]`.
     #[serde(rename = "lambdas")]
     pub lambdas: Option<Vec<String>>,
+    /// Log source configuration.
+    #[serde(rename = "log_source_config")]
+    pub log_source_config: Option<crate::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig>,
     /// List of service IDs set to enable automatic log collection. Discover the list of available services with the
     /// [Get list of AWS log ready services](<https://docs.datadoghq.com/api/latest/aws-logs-integration/#get-list-of-aws-log-ready-services>) endpoint.
     #[serde(rename = "sources")]
@@ -30,6 +33,7 @@ impl AWSLambdaForwarderConfig {
     pub fn new() -> AWSLambdaForwarderConfig {
         AWSLambdaForwarderConfig {
             lambdas: None,
+            log_source_config: None,
             sources: None,
             additional_properties: std::collections::BTreeMap::new(),
             _unparsed: false,
@@ -41,6 +45,14 @@ impl AWSLambdaForwarderConfig {
         self
     }
 
+    pub fn log_source_config(
+        mut self,
+        value: crate::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig,
+    ) -> Self {
+        self.log_source_config = Some(value);
+        self
+    }
+
     pub fn sources(mut self, value: Vec<String>) -> Self {
         self.sources = Some(value);
         self
@@ -79,6 +91,9 @@ impl<'de> Deserialize<'de> for AWSLambdaForwarderConfig {
                 M: MapAccess<'a>,
             {
                 let mut lambdas: Option<Vec<String>> = None;
+                let mut log_source_config: Option<
+                    crate::datadogV2::model::AWSLambdaForwarderConfigLogSourceConfig,
+                > = None;
                 let mut sources: Option<Vec<String>> = None;
                 let mut additional_properties: std::collections::BTreeMap<
                     String,
@@ -94,6 +109,13 @@ impl<'de> Deserialize<'de> for AWSLambdaForwarderConfig {
                             }
                             lambdas = Some(serde_json::from_value(v).map_err(M::Error::custom)?);
                         }
+                        "log_source_config" => {
+                            if v.is_null() {
+                                continue;
+                            }
+                            log_source_config =
+                                Some(serde_json::from_value(v).map_err(M::Error::custom)?);
+                        }
                         "sources" => {
                             if v.is_null() {
                                 continue;
@@ -110,6 +132,7 @@ impl<'de> Deserialize<'de> for AWSLambdaForwarderConfig {
 
                 let content = AWSLambdaForwarderConfig {
                     lambdas,
+                    log_source_config,
                     sources,
                     additional_properties,
                     _unparsed,

src/datadogV2/model/model_aws_lambda_forwarder_config_log_source_config.rs

@@ -0,0 +1,110 @@
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache-2.0 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/).
+// Copyright 2019-Present Datadog, Inc.
+use serde::de::{Error, MapAccess, Visitor};
+use serde::{Deserialize, Deserializer, Serialize};
+use serde_with::skip_serializing_none;
+use std::fmt::{self, Formatter};
+
+/// Log source configuration.
+#[non_exhaustive]
+#[skip_serializing_none]
+#[derive(Clone, Debug, PartialEq, Serialize)]
+pub struct AWSLambdaForwarderConfigLogSourceConfig {
+    /// List of AWS log source tag filters. Defaults to `[]`.
+    #[serde(rename = "tag_filters")]
+    pub tag_filters: Option<Vec<crate::datadogV2::model::AWSLogSourceTagFilter>>,
+    #[serde(flatten)]
+    pub additional_properties: std::collections::BTreeMap<String, serde_json::Value>,
+    #[serde(skip)]
+    #[serde(default)]
+    pub(crate) _unparsed: bool,
+}
+
+impl AWSLambdaForwarderConfigLogSourceConfig {
+    pub fn new() -> AWSLambdaForwarderConfigLogSourceConfig {
+        AWSLambdaForwarderConfigLogSourceConfig {
+            tag_filters: None,
+            additional_properties: std::collections::BTreeMap::new(),
+            _unparsed: false,
+        }
+    }
+
+    pub fn tag_filters(
+        mut self,
+        value: Vec<crate::datadogV2::model::AWSLogSourceTagFilter>,
+    ) -> Self {
+        self.tag_filters = Some(value);
+        self
+    }
+
+    pub fn additional_properties(
+        mut self,
+        value: std::collections::BTreeMap<String, serde_json::Value>,
+    ) -> Self {
+        self.additional_properties = value;
+        self
+    }
+}
+
+impl Default for AWSLambdaForwarderConfigLogSourceConfig {
+    fn default() -> Self {
+        Self::new()
+    }
+}
+
+impl<'de> Deserialize<'de> for AWSLambdaForwarderConfigLogSourceConfig {
+    fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
+    where
+        D: Deserializer<'de>,
+    {
+        struct AWSLambdaForwarderConfigLogSourceConfigVisitor;
+        impl<'a> Visitor<'a> for AWSLambdaForwarderConfigLogSourceConfigVisitor {
+            type Value = AWSLambdaForwarderConfigLogSourceConfig;
+
+            fn expecting(&self, f: &mut Formatter<'_>) -> fmt::Result {
+                f.write_str("a mapping")
+            }
+
+            fn visit_map<M>(self, mut map: M) -> Result<Self::Value, M::Error>
+            where
+                M: MapAccess<'a>,
+            {
+                let mut tag_filters: Option<Vec<crate::datadogV2::model::AWSLogSourceTagFilter>> =
+                    None;
+                let mut additional_properties: std::collections::BTreeMap<
+                    String,
+                    serde_json::Value,
+                > = std::collections::BTreeMap::new();
+                let mut _unparsed = false;
+
+                while let Some((k, v)) = map.next_entry::<String, serde_json::Value>()? {
+                    match k.as_str() {
+                        "tag_filters" => {
+                            if v.is_null() {
+                                continue;
+                            }
+                            tag_filters =
+                                Some(serde_json::from_value(v).map_err(M::Error::custom)?);
+                        }
+                        &_ => {
+                            if let Ok(value) = serde_json::from_value(v.clone()) {
+                                additional_properties.insert(k, value);
+                            }
+                        }
+                    }
+                }
+
+                let content = AWSLambdaForwarderConfigLogSourceConfig {
+                    tag_filters,
+                    additional_properties,
+                    _unparsed,
+                };
+
+                Ok(content)
+            }
+        }
+
+        deserializer.deserialize_any(AWSLambdaForwarderConfigLogSourceConfigVisitor)
+    }
+}