--- title: "SparkPipe | Connectors | MongoDB Time-Series" slug: "sparkpipe-connectors-mongodb-time-series" description: "SparkPipe is a cloud-native service that utilizes the MQTT Sparkplug specification to securely connect to any MQTT 3.1 compatible broker, capturing all the events published by any Sparkplug-enabled edge node, and routing this data to cloud-based services and applications such as Apache Kafka, etc." updated: 2025-09-30T15:55:37Z published: 2025-12-19T15:12:25Z canonical: "docs.n3uron.com/sparkpipe-connectors-mongodb-time-series" --- > ## Documentation Index > Fetch the complete documentation index at: https://docs.n3uron.com/llms.txt > Use this file to discover all available pages before exploring further. # MongoDB Time-Series ## Overview The MongoDB connector inserts all the Sparkplug metrics into a [MongoDB Time-Series](https://www.mongodb.com/products/capabilities/time-series) collection including the context and metadata provided by the Sparkplug protocol. ![](https://cdn.document360.io/54093ab5-6b22-4542-a265-04377931f11a/Images/Documentation/AWS-N3-SparkPipe-Architecture-03.png) ### Each event stored in the database contains the following: - The event **timestamp**, **name**, **data type** and **value.** - The Sparkplug metadata in the **meta** object. - The Sparkplug properties (if any) in the **properties** object. ![](https://cdn.document360.io/54093ab5-6b22-4542-a265-04377931f11a/Images/Documentation/image(38).png) ## Configuration The default configuration for the MongoDB connector: ```ini ... # Connectors configuration [connectors]  name = "mongo" # MongoDB [connectors.mongo]  # Connection URI  # Example:  #   - mongodb+srv://:@cluster.8wkd5pc.mongodb.net/?retryWrites=true&w=majority  uri = ""  # SSL/TLS configuration  tls_enabled                = true  tls_client_certificate     = ""  tls_client_certificate_key = ""  tls_certificate_authority  = ""  tls_insecure_skip_verify   = false  # Name of the database  database = "enterprise"  # Name of the time-series collection  collection = "uns-data" ``` #### Atlas Cluster Example configuration to securely connect with a [MongoDB Atlas](https://www.mongodb.com/products/platform/atlas-database) cluster using [SCRAM-SHA-256 authentication](https://www.mongodb.com/docs/manual/core/security-scram/) (username/password) and TLS encryption: ```ini ... # Connectors configuration [connectors]  name = "mongo" # MongoDB [connectors.mongo]  # Connection URI  uri = "mongodb+srv://:@cluster.8qjd4ff.mongodb.net/?retryWrites=true&w=majority"  # SSL/TLS configuration  tls_enabled                = true  tls_client_certificate     = ""  tls_client_certificate_key = ""  tls_certificate_authority  = ""  tls_insecure_skip_verify   = false  # Name of the database  database = "enterprise"  # Name of the time-series collection  collection = "uns-data" ``` #### Atlas Cluster with mTLS Example configuration to securely connect to a [MongoDB Atlas](https://www.mongodb.com/products/platform/atlas-database) cluster using [mutual TLS authentication](https://www.mongodb.com/docs/manual/core/security-x.509/) with x.509 certificates: ```ini ... # Connectors configuration [connectors]  name = "mongo" # MongoDB [connectors.mongo]  # Connection URI  uri = "mongodb+srv://cluster.8qjd4ff.mongodb.net/?retryWrites=true&w=majority"  # SSL/TLS configuration  tls_enabled                = true  tls_client_certificate     = "/etc/sparkpipe/certs/client.crt"  tls_client_certificate_key = "/etc/sparkpipe/certs/client.key"  tls_certificate_authority  = "/etc/sparkpipe/certs/ca.crt"  tls_insecure_skip_verify   = false  # Name of the database  database = "enterprise"  # Name of the time-series collection  collection = "uns-data" ``` #### Self-Managed Database Example configuration to connect with a self-managed MongoDB database in the same VPC. ```ini ... # Connectors configuration [connectors]  name = "mongo" # MongoDB [connectors.mongo]  # Connection URI  uri = "mongodb://ip-192-168-1-10.us-west-2.compute.internal:27017/?retryWrites=true&tls=false"  # SSL/TLS configuration  tls_enabled                = false  tls_client_certificate     = ""  tls_client_certificate_key = ""  tls_certificate_authority  = ""  tls_insecure_skip_verify   = false  # Name of the database  database = "enterprise"  # Name of the time-series collection  collection = "uns-data" ```