mongodb

README

---
title: "MongoDB"
lang: "en-US"
draft: false
description: "Learn about how to set up a VDP MongoDB component https://github.com/instill-ai/instill-core"
---

The MongoDB component is a data component that allows users to access the MongoDB NoSQL database.
It can carry out the following tasks:

- [Insert](#insert)
- [Insert Many](#insert-many)
- [Find](#find)
- [Update](#update)
- [Delete](#delete)
- [Drop Collection](#drop-collection)
- [Drop Database](#drop-database)
- [Create Search Index](#create-search-index)
- [Drop Search Index](#drop-search-index)
- [Vector Search](#vector-search)



## Release Stage

`Alpha`



## Configuration

The component configuration is defined and maintained [here](https://github.com/instill-ai/component/blob/main/data/mongodb/v0/config/definition.json).




## Setup




In order to communicate with MongoDB, the following connection details need to be
provided. You may specify them directly in a pipeline recipe as key-value pairs
withing the component's `setup` block, or you can create a **Connection** from
the [**Integration Settings**](https://www.instill.tech/docs/vdp/integration)
page and reference the whole `setup` as `setup:
${connection.<my-connection-id>}`.

| Field | Field ID | Type | Note |
| :--- | :--- | :--- | :--- |
| URI (required) | `uri` | string | Fill in your MongoDB URI |




## Supported Tasks

### Insert

Perform an insert operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_INSERT` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| ID | `id` | string | The ID of the document |
| Data (required) | `data` | object | The data to be inserted |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Insert status |






### Insert Many

Perform an insert many operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_INSERT_MANY` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| Array ID | `array-id` | array[string] | The array of id |
| Data (required) | `array-data` | array[object] | The array data to be inserted |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Insert many status |






### Find

Perform a find operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_FIND` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| ID | `id` | string | The ID of the document |
| Filter | `filter` | object | The filter to find documents, please refer to the documentations https://www.mongodb.com/docs/manual/reference/operator/query/. If empty then all documents will be returned |
| Limit | `limit` | integer | The number of documents to return. If empty then all documents will be returned |
| Fields | `fields` | array[string] | The fields to return in the documents. If empty then all fields will be returned |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Result | `result` | object | Result of the find operation |
| Status | `status` | string | Find status |






### Update

Perform an update operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_UPDATE` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| ID | `id` | string | The ID of the document |
| Filter | `filter` | object | The filter to update documents, please refer to the documentations https://www.mongodb.com/docs/manual/reference/operator/query/. If empty then all documents will be returned |
| Update (required) | `update-data` | object | The updated data to be applied to the documents |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Update status |






### Delete

Perform a delete operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_DELETE` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| ID | `id` | string | The ID of the document |
| Filter | `filter` | object | The filter to delete documents, please refer to the documentations https://www.mongodb.com/docs/manual/reference/operator/query/. If empty then all documents will be returned |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Delete status |






### Drop Collection

Delete the collection


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_DROP_COLLECTION` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Delete collection status |






### Drop Database

Delete the database


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_DROP_DATABASE` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Delete database status |






### Create Search Index

Create a search index, only works for M10 or larger clusters


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_CREATE_SEARCH_INDEX` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| Index Name (required) | `index-name` | string | The name of the index to be created |
| Index Type (required) | `index-type` | string | The type of the index to be created |
| Syntax (required) | `syntax` | object | The syntax structure of the search index, please refer to the MongoDB documentation for more information. search https://www.mongodb.com/docs/atlas/atlas-search/create-index/. vectorSearch https://www.mongodb.com/docs/atlas/atlas-vector-search/vector-search-type/ |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Create index status |






### Drop Search Index

Drop a search index, only works for M10 or larger clusters


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_DROP_SEARCH_INDEX` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| Index Name (required) | `index-name` | string | The name of the index to be dropped |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Status | `status` | string | Delete index status |






### Vector Search

Perform a vector search operation


| Input | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Task ID (required) | `task` | string | `TASK_VECTOR_SEARCH` |
| Database Name (required) | `database-name` | string | The name of the database in MongoDB |
| Collection Name (required) | `collection-name` | string | The name of the collection in MongoDB |
| Index Name (required) | `index-name` | string | The name of the index to be used for vector search |
| Query Vector (required) | `query-vector` | array[number] | The query vector to be used for vector search |
| Exact | `exact` | boolean | The exact value for vector search. If true, then ENN search will be performed, otherwise ANN search will be performed. Default to false |
| Limit (required) | `limit` | integer | Limit the documents to be returned |
| Number of Candidates | `num-candidates` | integer | The number of candidates to the field to be used for vector search. Default to 3 times limit |
| Path (required) | `path` | string | The path to the field to be used for vector search |
| Filter | `filter` | object | The filter to be used for vector search, need to first create filter vectorSearch search index, please refer to the documentations https://www.mongodb.com/docs/manual/reference/operator/query/. If empty then all documents will be returned to be used for vector search |
| Fields | `fields` | array[string] | The fields to return in the documents. If empty then all fields will be returned |



| Output | ID | Type | Description |
| :--- | :--- | :--- | :--- |
| Result | `result` | object | Result of the vector search operation |
| Status | `status` | string | Vector search status |

Documentation

Index

• Constants
• func Init(bc base.Component) *component
• type CreateSearchIndexInput
• type CreateSearchIndexOutput
• type DeleteInput
• type DeleteOutput
• type DropCollectionInput
• type DropCollectionOutput
• type DropDatabaseInput
• type DropDatabaseOutput
• type DropSearchIndexInput
• type DropSearchIndexOutput
• type FindInput
• type FindOutput
• type FindResult
• type InsertInput
• type InsertManyInput
• type InsertManyOutput
• type InsertOutput
• type MongoClient
• type MongoCollectionClient
• type MongoDatabaseClient
• type MongoSearchIndexClient
• type UpdateInput
• type UpdateOutput
• type VectorResult
• type VectorSearchInput
• type VectorSearchOutput

Constants

const (
	TaskInsert            = "TASK_INSERT"
	TaskInsertMany        = "TASK_INSERT_MANY"
	TaskFind              = "TASK_FIND"
	TaskUpdate            = "TASK_UPDATE"
	TaskDelete            = "TASK_DELETE"
	TaskDropCollection    = "TASK_DROP_COLLECTION"
	TaskDropDatabase      = "TASK_DROP_DATABASE"
	TaskCreateSearchIndex = "TASK_CREATE_SEARCH_INDEX"
	TaskDropSearchIndex   = "TASK_DROP_SEARCH_INDEX"
	TaskVectorSearch      = "TASK_VECTOR_SEARCH"
)

Functions

func Init

func Init(bc base.Component) *component

Init returns an implementation of IConnector that interacts with MongoDB.

Types

type CreateSearchIndexInput

type CreateSearchIndexInput struct {
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	IndexName      string         `json:"index-name"`
	IndexType      string         `json:"index-type"`
	Syntax         map[string]any `json:"syntax"`
}

type CreateSearchIndexOutput

type CreateSearchIndexOutput struct {
	Status string `json:"status"`
}

type DeleteInput

type DeleteInput struct {
	ID             string         `json:"id"`
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	Filter         map[string]any `json:"filter"`
}

type DeleteOutput

type DeleteOutput struct {
	Status string `json:"status"`
}

type DropCollectionInput

type DropCollectionInput struct {
	DatabaseName   string `json:"database-name"`
	CollectionName string `json:"collection-name"`
}

type DropCollectionOutput

type DropCollectionOutput struct {
	Status string `json:"status"`
}

type DropDatabaseInput

type DropDatabaseInput struct {
	DatabaseName string `json:"database-name"`
}

type DropDatabaseOutput

type DropDatabaseOutput struct {
	Status string `json:"status"`
}

type DropSearchIndexInput

type DropSearchIndexInput struct {
	DatabaseName   string `json:"database-name"`
	CollectionName string `json:"collection-name"`
	IndexName      string `json:"index-name"`
}

type DropSearchIndexOutput

type DropSearchIndexOutput struct {
	Status string `json:"status"`
}

type FindInput

type FindInput struct {
	ID             string         `json:"id"`
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	Filter         map[string]any `json:"filter"`
	Limit          int            `json:"limit"`
	Fields         []string       `json:"fields"`
}

type FindOutput

type FindOutput struct {
	Status string     `json:"status"`
	Result FindResult `json:"result"`
}

type FindResult

type FindResult struct {
	IDs       []string         `json:"ids"`
	Documents []map[string]any `json:"documents"`
	Data      []map[string]any `json:"data"`
}

type InsertInput

type InsertInput struct {
	ID             string         `json:"id"`
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	Data           map[string]any `json:"data"`
}

type InsertManyInput

type InsertManyInput struct {
	ArrayID        []string         `json:"array-id"`
	DatabaseName   string           `json:"database-name"`
	CollectionName string           `json:"collection-name"`
	ArrayData      []map[string]any `json:"array-data"`
}

type InsertManyOutput

type InsertManyOutput struct {
	Status string `json:"status"`
}

type InsertOutput

type InsertOutput struct {
	Status string `json:"status"`
}

type MongoClient

type MongoClient struct {
	// contains filtered or unexported fields
}

type MongoCollectionClient

type MongoCollectionClient interface {
	Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (cur *mongo.Cursor, err error)
	InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
	InsertMany(ctx context.Context, documents []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)
	UpdateMany(ctx context.Context, filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)
	DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
	Drop(ctx context.Context) error

	SearchIndexes() mongo.SearchIndexView
	Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)
}

type MongoDatabaseClient

type MongoDatabaseClient interface {
	Drop(ctx context.Context) error
}

type MongoSearchIndexClient

type MongoSearchIndexClient interface {
	CreateOne(ctx context.Context, model mongo.SearchIndexModel, opts ...*options.CreateSearchIndexesOptions) (string, error)
	DropOne(ctx context.Context, name string, _ ...*options.DropSearchIndexOptions) error
}

type UpdateInput

type UpdateInput struct {
	ID             string         `json:"id"`
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	Filter         map[string]any `json:"filter"`
	UpdateData     map[string]any `json:"update-data"`
}

type UpdateOutput

type UpdateOutput struct {
	Status string `json:"status"`
}

type VectorResult

type VectorResult struct {
	IDs       []string         `json:"ids"`
	Documents []map[string]any `json:"documents"`
	Vectors   [][]float64      `json:"vectors"`
	Metadata  []map[string]any `json:"metadata"`
}

type VectorSearchInput

type VectorSearchInput struct {
	DatabaseName   string         `json:"database-name"`
	CollectionName string         `json:"collection-name"`
	Exact          bool           `json:"exact"`
	Filter         map[string]any `json:"filter"`
	IndexName      string         `json:"index-name"`
	Limit          int            `json:"limit"`
	NumCandidates  int            `json:"num-candidates"`
	Path           string         `json:"path"`
	QueryVector    []float64      `json:"query-vector"`
	Fields         []string       `json:"fields"`
}

type VectorSearchOutput

type VectorSearchOutput struct {
	Status string       `json:"status"`
	Result VectorResult `json:"result"`
}