> ## Documentation Index
> Fetch the complete documentation index at: https://docs.getnetra.ai/llms.txt
> Use this file to discover all available pages before exploring further.

# Marqo

> Trace Marqo vector search operations with Netra auto-instrumentation. Monitor index queries, document inserts, and multimodal search automatically.

<img src="https://mintcdn.com/netra/IXT7TOAHn4HQhvyF/images/integration-logos/vector-databases/marqo.png?fit=max&auto=format&n=IXT7TOAHn4HQhvyF&q=85&s=5b2742bbed1a37942bdacd7add069522" alt="Marqo" width="360" height="80" data-path="images/integration-logos/vector-databases/marqo.png" />

## Installation

Install both the Netra SDK and Marqo:

<CodeGroup>
  ```bash Python theme={null}
  pip install netra-sdk marqo
  ```

  ```bash Typescript theme={null}
  npm install netra-sdk marqo
  ```
</CodeGroup>

## Usage

Initialize the Netra SDK to automatically trace all Marqo operations:

<CodeGroup>
  ```python Python theme={null}
  from netra import Netra
  import marqo
  import os

  # Initialize Netra
  Netra.init(
      headers=f"x-api-key={os.environ.get('NETRA_API_KEY')}",
      trace_content=True
  )

  # Create Marqo client - automatically traced
  mq = marqo.Client(
      url=os.environ.get('MARQO_URL'),
      api_key=os.environ.get('MARQO_API_KEY')
  )

  # Create index
  mq.create_index("my-index")

  # Add documents
  mq.index("my-index").add_documents([
      {"title": "Document 1", "content": "Content here"}
  ])
  ```

  ```typescript Typescript theme={null}
  import { Netra } from "netra-sdk";
  import marqo from "marqo";

  // Initialize Netra
  await Netra.init({
    headers: `x-api-key=${process.env.NETRA_API_KEY}`,
    traceContent: true
  });

  // Create Marqo client - automatically traced
  const client = new marqo.Client({
    url: process.env.MARQO_URL,
    apiKey: process.env.MARQO_API_KEY
  });

  // Create index
  await client.createIndex("my-index");

  // Add documents
  await client.index("my-index").addDocuments([
    { title: "Document 1", content: "Content here" }
  ]);
  ```
</CodeGroup>

### Index Operations

Trace index creation and management:

<CodeGroup>
  ```python Python theme={null}
  from netra.decorators import task
  from netra import SpanWrapper

  @task()
  def create_index(mq, index_name: str):
      span = SpanWrapper("marqo-create-index", {
          "index.name": index_name
      }).start()
      
      mq.create_index(
          index_name,
          model="hf/e5-base-v2"
      )
      
      span.end()
  ```

  ```typescript Typescript theme={null}
  import { task, SpanWrapper } from "netra-sdk";

  @task()
  async function createIndex(client: any, indexName: string) {
    const span = new SpanWrapper("marqo-create-index", {
      "index.name": indexName
    }).start();
    
    await client.createIndex(indexName, {
      model: "hf/e5-base-v2"
    });
    
    span.end();
  }
  ```
</CodeGroup>

### Document Insertion

Trace document additions:

<CodeGroup>
  ```python Python theme={null}
  from netra.decorators import task
  from netra import SpanWrapper, ActionModel

  @task()
  def add_documents(mq, index_name: str, documents: list):
      span = SpanWrapper("marqo-add-documents", {
          "index.name": index_name,
          "documents.count": len(documents)
      }).start()
      
      result = mq.index(index_name).add_documents(documents)
      
      span.set_action([ActionModel(
          action="insert",
          action_type="database.insert",
          success=result["status"] == "succeeded",
          affected_records=[{"id": d.get("id") or d.get("_id")} for d in documents],
          metadata={"index": index_name}
      )])
      span.set_attribute("status", result["status"])
      span.end()
      
      return result
  ```

  ```typescript Typescript theme={null}
  import { task, SpanWrapper, ActionModel } from "netra-sdk";

  @task()
  async function addDocuments(client: any, indexName: string, documents: any[]) {
    const span = new SpanWrapper("marqo-add-documents", {
      "index.name": indexName,
      "documents.count": documents.length
    }).start();
    
    const result = await client.index(indexName).addDocuments(documents);
    
    span.setAction([{
      action: "insert",
      action_type: "database.insert",
      success: result.status === "succeeded",
      affected_records: documents.map(d => ({ id: d.id || d._id })),
      metadata: { index: indexName }
    }]);
    span.setAttribute("status", result.status);
    span.end();
    
    return result;
  }
  ```
</CodeGroup>

### Semantic Search

Trace text-based searches:

<CodeGroup>
  ```python Python theme={null}
  from netra.decorators import workflow
  from netra import SpanWrapper

  @workflow()
  def search_documents(mq, index_name: str, query: str, limit: int = 5):
      span = SpanWrapper("marqo-search", {
          "index.name": index_name,
          "query": query,
          "limit": limit
      }).start()
      
      results = mq.index(index_name).search(
          q=query,
          limit=limit
      )
      
      span.set_attribute("results.count", len(results["hits"]))
      span.end()
      
      return results
  ```

  ```typescript Typescript theme={null}
  import { workflow, SpanWrapper } from "netra-sdk";

  @workflow()
  async function searchDocuments(client: any, indexName: string, query: string, limit: number = 5) {
    const span = new SpanWrapper("marqo-search", {
      "index.name": indexName,
      "query": query,
      "limit": limit
    }).start();
    
    const results = await client.index(indexName).search(query, {
      limit: limit
    });
    
    span.setAttribute("results.count", results.hits.length);
    span.end();
    
    return results;
  }
  ```
</CodeGroup>

### Multimodal Search

Trace image and text searches:

<CodeGroup>
  ```python Python theme={null}
  from netra.decorators import task
  from netra import SpanWrapper

  @task()
  def multimodal_search(mq, index_name: str, query: dict):
      span = SpanWrapper("marqo-multimodal-search", {
          "index.name": index_name
      }).start()
      
      results = mq.index(index_name).search(
          q=query,
          searchable_attributes=["title", "content", "image_url"]
      )
      
      span.set_attribute("results.count", len(results["hits"]))
      span.end()
      
      return results
  ```

  ```typescript Typescript theme={null}
  import { task, SpanWrapper } from "netra-sdk";

  @task()
  async function multimodalSearch(client: any, indexName: string, query: any) {
    const span = new SpanWrapper("marqo-multimodal-search", {
      "index.name": indexName
    }).start();
    
    const results = await client.index(indexName).search(query, {
      searchableAttributes: ["title", "content", "image_url"]
    });
    
    span.setAttribute("results.count", results.hits.length);
    span.end();
    
    return results;
  }
  ```
</CodeGroup>

### Filtered Search

Trace searches with filters:

<CodeGroup>
  ```python Python theme={null}
  from netra.decorators import task
  from netra import SpanWrapper

  @task()
  def filter_search(mq, index_name: str, query: str, filter: str):
      span = SpanWrapper("marqo-filter-search", {
          "index.name": index_name,
          "filter": filter
      }).start()
      
      results = mq.index(index_name).search(
          q=query,
          filter_string=filter
      )
      
      span.set_attribute("results.count", len(results["hits"]))
      span.end()
      
      return results
  ```

  ```typescript Typescript theme={null}
  import { task, SpanWrapper } from "netra-sdk";

  @task()
  async function filterSearch(client: any, indexName: string, query: string, filter: string) {
    const span = new SpanWrapper("marqo-filter-search", {
      "index.name": indexName,
      "filter": filter
    }).start();
    
    const results = await client.index(indexName).search(query, {
      filter: filter
    });
    
    span.setAttribute("results.count", results.hits.length);
    span.end();
    
    return results;
  }
  ```
</CodeGroup>

## Next Steps

* [Quick Start Guide](https://docs.getnetra.ai/quick-start/python) - Complete setup and configuration
* [Decorators](https://docs.getnetra.ai/tracing/decorators) - Add custom tracing with `@workflow`, `@agent`, and `@task` decorators
* [Marqo Documentation](https://docs.marqo.ai/) - Official Marqo documentation