diff --git a/monitoring.tf b/monitoring.tf
index 89a1e62..b7c2a00 100644
--- a/monitoring.tf
+++ b/monitoring.tf
@@ -5,6 +5,7 @@ locals {
     var.enable_glue_create ? lower(var.glue_create_config.sqs_queue_name_dl) : local.base_dlq_name,
     var.enable_glue_sync ? lower(var.glue_sync_config.sqs_queue_name_dl) : local.base_dlq_name,
   ]
+  additional_query_conditions = length(var.monitoring_query_conditions) > 0 ? ", ${var.monitoring_query_conditions}" : ""
 }
 
 resource "datadog_monitor" "dead_letters_monitor" {
@@ -17,7 +18,7 @@ resource "datadog_monitor" "dead_letters_monitor" {
     dead_letters_queue_name = each.key
     notify                  = join(", ", var.dl_alert_recipients)
   })
-  query = "avg(last_1h):avg:aws.sqs.approximate_number_of_messages_visible{queuename:${each.key}} > ${var.dl_critical}"
+  query = "avg(last_1h):avg:aws.sqs.approximate_number_of_messages_visible{queuename:${each.key}${local.additional_query_conditions}} > ${var.dl_critical}"
 
   monitor_thresholds {
     warning  = var.dl_warning
diff --git a/variables.tf b/variables.tf
index 4049e6e..da3e748 100644
--- a/variables.tf
+++ b/variables.tf
@@ -247,6 +247,12 @@ variable "tags_monitoring" {
   description = "A list of tags to assign to the monitoring resource"
 }
 
+variable "monitoring_query_conditions" {
+  type        = string
+  description = "Monitoring query conditions a comma peratde key:value pair list"
+  default     = ""
+}
+
 variable "enable_aws_glue_catalog_table" {
   type        = bool
   description = "Enable glue catalog table"