Octodet Elasticsearch MCP सर्वर

Octodet Elasticsearch MCP सर्वर

Octodet Elasticsearch MCP सर्वर एक शक्तिशाली मॉडल संदर्भ प्रोटोकॉल (MCP) सर्वर है जिसे Elasticsearch क्लस्टरों के साथ सहज इंटरैक्शन के लिए डिज़ाइन किया गया है। यह LLM-संचालित अनुप्रयोगों के लिए Elasticsearch के भीतर डेटा प्रबंधन, खोजने और अपडेट करने जैसी विभिन्न ऑपरेशनों को करने का एक मानकीकृत तरीका प्रदान करता है।

विशेषताएँ

• पूर्ण Elasticsearch ऑपरेशन्स: दस्तावेज़ों और अनुक्रमणिकाओं पर पूर्ण CRUD ऑपरेशन्स को आसानी से निष्पादित करें।
• बल्क ऑपरेशन्स: एकल API कॉल में कई ऑपरेशन्स को प्रोसेस करके प्रदर्शन को बढ़ाएँ।
• क्वेरी-आधारित अपडेट/डिलीट: विशिष्ट क्वेरी के आधार पर दस्तावेज़ों को संशोधित या हटाएँ।
• क्लस्टर प्रबंधन: अपने Elasticsearch क्लस्टर की स्वास्थ्य की निगरानी करें, जिसमें शार्द और टेम्पलेट शामिल हैं।
• उन्नत खोज: अंतर्निहित हाइलाइटिंग समर्थन के साथ Elasticsearch DSL क्वेरी की पूर्ण क्षमताओं का उपयोग करें।

कैसे स्थापित करें

NPM पैकेज के रूप में

Octodet Elasticsearch MCP सर्वर को वैश्विक रूप से स्थापित करने के लिए, चलाएँ:

npm install -g @octodet/elasticsearch-mcp

वैकल्पिक रूप से, आप इसे सीधे npx के साथ उपयोग कर सकते हैं:

npx @octodet/elasticsearch-mcp

स्रोत से

1. रिपॉजिटरी को क्लोन करें।
2. आवश्यक निर्भरताएँ स्थापित करें:

npm install

3. सर्वर बनाएं:

npm run build

MCP क्लाइंट्स के साथ एकीकरण

VS कोड एकीकरण

VS कोड MCP एक्सटेंशन के साथ एकीकृत करने के लिए, अपने settings.json में निम्नलिखित कॉन्फ़िगरेशन जोड़ें:

"mcp.servers": {
  "elasticsearch": {
    "command": "npx",
    "args": [
      "-y", "@octodet/elasticsearch-mcp"
    ],
    "env": {
      "ES_URL": "http://localhost:9200",
      "ES_API_KEY": "your_api_key",
      "ES_VERSION": "8"
    }
  }
}

क्लॉड डेस्कटॉप एकीकरण

क्लॉड डेस्कटॉप के लिए, अपने सेटिंग्स को निम्नलिखित के रूप में कॉन्फ़िगर करें:

{
  "mcpServers": {
    "elasticsearch": {
      "command": "npx",
      "args": ["-y", "@octodet/elasticsearch-mcp"],
      "env": {
        "ES_URL": "http://localhost:9200",
        "ES_API_KEY": "your_api_key",
        "ES_VERSION": "8"
      }
    }
  }
}

स्थानीय विकास के लिए

यदि आप स्थानीय रूप से MCP सर्वर विकसित कर रहे हैं, तो अपने क्लाइंट्स को अपने स्थानीय निर्माण का उपयोग करने के लिए कॉन्फ़िगर करें:

{
  "mcpServers": {
    "elasticsearch": {
      "command": "node",
      "args": ["path/to/build/index.js"],
      "env": {
        "ES_URL": "http://localhost:9200",
        "ES_API_KEY": "your_api_key",
        "ES_VERSION": "8"
      }
    }
  }
}

कॉन्फ़िगरेशन

सर्वर को निम्नलिखित पर्यावरण चर का उपयोग करके कॉन्फ़िगर किया जा सकता है:

| चर | विवरण | डिफ़ॉल्ट | | | | | | ES_URL | Elasticsearch सर्वर URL | http://localhost:9200 | | ES_API_KEY | प्रमाणीकरण के लिए API कुंजी | | | ES_USERNAME | प्रमाणीकरण के लिए उपयोगकर्ता नाम | | | ES_PASSWORD | प्रमाणीकरण के लिए पासवर्ड | | | ES_CA_CERT | कस्टम CA प्रमाणपत्र का पथ | | | ES_VERSION | Elasticsearch संस्करण (8 या 9) | 8 | | ES_SSL_SKIP_VERIFY | SSL सत्यापन छोड़ें | false | | ES_PATH_PREFIX | Elasticsearch के लिए पथ उपसर्ग | |

उपकरण

सर्वर में विभिन्न Elasticsearch ऑपरेशन्स के लिए 16 MCP उपकरण शामिल हैं, प्रत्येक के साथ आवश्यक और वैकल्पिक पैरामीटर के साथ दस्तावेज़ित किया गया है।

1. अनुक्रमणिकाएँ सूचीबद्ध करें

सभी उपलब्ध Elasticsearch अनुक्रमणिकाओं की सूची प्राप्त करें जिसमें विस्तृत जानकारी हो।

पैरामीटर:

• indexPattern (वैकल्पिक, स्ट्रिंग): अनुक्रमणिकाओं को फ़िल्टर करने के लिए पैटर्न (जैसे, "logs-", "my-index-")

उदाहरण:

{
  "indexPattern": "logs-*"
}

2. मैपिंग प्राप्त करें

विशिष्ट Elasticsearch अनुक्रमणिका के लिए फ़ील्ड मैपिंग प्राप्त करें।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): उस अनुक्रमणिका का नाम जिसके लिए मैपिंग प्राप्त करनी है।

उदाहरण:

{
  "index": "my-index"
}

3. खोजें

प्रदान की गई क्वेरी DSL और हाइलाइटिंग का उपयोग करके Elasticsearch में खोज करें।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): उस अनुक्रमणिका या अनुक्रमणिकाओं को खोजने के लिए (कोमा से पृथक मानों का समर्थन करता है)।
• queryBody (आवश्यक, ऑब्जेक्ट): Elasticsearch क्वेरी DSL बॉडी।
• highlight (वैकल्पिक, बूलियन): खोज परिणामों के लिए हाइलाइटिंग सक्षम करें (डिफ़ॉल्ट: true)।

उदाहरण:

{
  "index": "my-index",
  "queryBody": {
    "query": {
      "match": {
        "content": "search term"
      }
    },
    "size": 10,
    "from": 0,
    "sort": [{ "_score": { "order": "desc" } }]
  },
  "highlight": true
}

4. क्लस्टर स्वास्थ्य प्राप्त करें

Elasticsearch क्लस्टर के बारे में स्वास्थ्य जानकारी प्राप्त करें।

पैरामीटर:

• कोई आवश्यक नहीं।

उदाहरण:

{}

5. शार्द प्राप्त करें

सभी या विशिष्ट अनुक्रमणिकाओं के लिए शार्द जानकारी प्राप्त करें।

पैरामीटर:

• index (वैकल्पिक, स्ट्रिंग): विशिष्ट अनुक्रमणिका जिसके लिए शार्द जानकारी प्राप्त करनी है। यदि छोड़ा गया, तो सभी अनुक्रमणिकाओं के लिए शार्द लौटाता है।

उदाहरण:

{
  "index": "my-index"
}

6. दस्तावेज़ जोड़ें

विशिष्ट Elasticsearch अनुक्रमणिका में एक नया दस्तावेज़ डालें।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): वह अनुक्रमणिका जिसमें दस्तावेज़ जोड़ा जाएगा।
• document (आवश्यक, ऑब्जेक्ट): जोड़ने के लिए दस्तावेज़ की सामग्री।
• id (वैकल्पिक, स्ट्रिंग): दस्तावेज़ ID। यदि छोड़ा गया, तो Elasticsearch स्वचालित रूप से एक उत्पन्न करता है।

उदाहरण:

{
  "index": "my-index",
  "id": "doc1",
  "document": {
    "title": "My Document",
    "content": "Document content here",
    "timestamp": "2025-06-23T10:30:00Z",
    "tags": ["important", "draft"]
  }
}

7. दस्तावेज़ अपडेट करें

विशिष्ट Elasticsearch अनुक्रमणिका में एक मौजूदा दस्तावेज़ को संशोधित करें।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): वह अनुक्रमणिका जिसमें दस्तावेज़ है।
• id (आवश्यक, स्ट्रिंग): अपडेट करने के लिए दस्तावेज़ का ID।
• document (आवश्यक, ऑब्जेक्ट): अपडेट करने के लिए फ़ील्ड के साथ आंशिक दस्तावेज़।

उदाहरण:

{
  "index": "my-index",
  "id": "doc1",
  "document": {
    "title": "Updated Document Title",
    "last_modified": "2025-06-23T10:30:00Z"
  }
}

8. दस्तावेज़ हटाएँ

विशिष्ट Elasticsearch अनुक्रमणिका से एक दस्तावेज़ हटाएँ।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): वह अनुक्रमणिका जिसमें दस्तावेज़ है।
• id (आवश्यक, स्ट्रिंग): हटाने के लिए दस्तावेज़ का ID।

उदाहरण:

{
  "index": "my-index",
  "id": "doc1"
}

9. क्वेरी द्वारा अपडेट करें

क्वेरी के आधार पर Elasticsearch अनुक्रमणिका में दस्तावेज़ों को अपडेट करें।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): वह अनुक्रमणिका जिसमें दस्तावेज़ों को अपडेट करना है।
• query (आवश्यक, ऑब्जेक्ट): दस्तावेज़ों को अपडेट करने के लिए मेल खाने के लिए Elasticsearch क्वेरी।
• script (आवश्यक, ऑब्जेक्ट): मेल खाने वाले दस्तावेज़ों को अपडेट करने के लिए निष्पादित करने के लिए स्क्रिप्ट।
• conflicts (वैकल्पिक, स्ट्रिंग): संस्करण संघर्षों को कैसे संभालना है ("abort" या "proceed", डिफ़ॉल्ट: "abort")।
• refresh (वैकल्पिक, बूलियन): ऑपरेशन के बाद अनुक्रमणिका को ताज़ा करने के लिए (डिफ़ॉल्ट: false)।

उदाहरण:

{
  "index": "my-index",
  "query": {
    "term": {
      "status": "active"
    }
  },
  "script": {
    "source": "ctx._source.status = params.newStatus; ctx._source.updated_at = params.timestamp",
    "params": {
      "newStatus": "inactive",
      "timestamp": "2025-06-23T10:30:00Z"
    }
  },
  "conflicts": "proceed",
  "refresh": true
}

10. क्वेरी द्वारा हटाएँ

क्वेरी के आधार पर Elasticsearch अनुक्रमणिका से दस्तावेज़ों को हटाएँ।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): वह अनुक्रमणिका जिसमें दस्तावेज़ों को हटाना है।
• query (आवश्यक, ऑब्जेक्ट): दस्तावेज़ों को हटाने के लिए मेल खाने के लिए Elasticsearch क्वेरी।
• conflicts (वैकल्पिक, स्ट्रिंग): संस्करण संघर्षों को कैसे संभालना है ("abort" या "proceed", डिफ़ॉल्ट: "abort")।
• refresh (वैकल्पिक, बूलियन): ऑपरेशन के बाद अनुक्रमणिका को ताज़ा करने के लिए (डिफ़ॉल्ट: false)।

उदाहरण:

{
  "index": "my-index",
  "query": {
    "range": {
      "created_date": {
        "lt": "2025-01-01"
      }
    }
  },
  "conflicts": "proceed",
  "refresh": true
}

11. बल्क ऑपरेशन्स

सुधारित प्रदर्शन के लिए एकल API कॉल में कई दस्तावेज़ ऑपरेशन्स को निष्पादित करें।

पैरामीटर:

• operations (आवश्यक, ऐरे): ऑपरेशन ऑब्जेक्ट्स का ऐरे, प्रत्येक में शामिल:
  • action (आवश्यक, स्ट्रिंग): ऑपरेशन प्रकार ("index", "create", "update", या "delete")।
  • index (आवश्यक, स्ट्रिंग): इस ऑपरेशन के लिए अनुक्रमणिका।
  • id (वैकल्पिक, स्ट्रिंग): दस्तावेज़ ID (अपडेट/हटाने के लिए आवश्यक, इंडेक्स/क्रिएट के लिए वैकल्पिक)।
  • document (शर्तीय, ऑब्जेक्ट): दस्तावेज़ की सामग्री (इंडेक्स/क्रिएट/अपडेट ऑपरेशन्स के लिए आवश्यक)।

उदाहरण:

{
  "operations": [
    {
      "action": "index",
      "index": "my-index",
      "id": "doc1",
      "document": { "title": "Document 1", "content": "Content here" }
    },
    {
      "action": "update",
      "index": "my-index",
      "id": "doc2",
      "document": { "title": "Updated Title" }
    },
    {
      "action": "delete",
      "index": "my-index",
      "id": "doc3"
    }
  ]
}

12. अनुक्रमणिका बनाएँ

वैकल्पिक सेटिंग्स और मैपिंग के साथ एक नई Elasticsearch अनुक्रमणिका बनाएँ।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): बनाने के लिए अनुक्रमणिका का नाम।
• settings (वैकल्पिक, ऑब्जेक्ट): अनुक्रमणिका सेटिंग्स जैसे शार्द की संख्या, प्रतिकृतियाँ, आदि।
• mappings (वैकल्पिक, ऑब्जेक्ट): फ़ील्ड मैपिंग जो यह परिभाषित करती है कि दस्तावेज़ों को कैसे अनुक्रमित किया जाना चाहिए।

उदाहरण:

{
  "index": "new-index",
  "settings": {
    "number_of_shards": 3,
    "number_of_replicas": 1,
    "analysis": {
      "analyzer": {
        "custom_analyzer": {
          "type": "standard",
          "stopwords": "_english_"
        }
      }
    }
  },
  "mappings": {
    "properties": {
      "title": {
        "type": "text",
        "analyzer": "custom_analyzer"
      },
      "created": {
        "type": "date",
        "format": "yyyy-MM-dd'T'HH:mm:ss'Z'"
      },
      "tags": {
        "type": "keyword"
      }
    }
  }
}

13. अनुक्रमणिका हटाएँ

एक Elasticsearch अनुक्रमणिका को स्थायी रूप से हटाएँ।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): हटाने के लिए अनुक्रमणिका का नाम।

उदाहरण:

{
  "index": "my-index"
}

14. दस्तावेज़ों की गणना करें

एक अनुक्रमणिका में दस्तावेज़ों की गणना करें, वैकल्पिक रूप से एक क्वेरी द्वारा फ़िल्टर किया गया।

पैरामीटर:

• index (आवश्यक, स्ट्रिंग): उस अनुक्रमणिका में दस्तावेज़ों की गणना करें।
• query (वैकल्पिक, ऑब्जेक्ट): दस्तावेज़ों को गिनने के लिए फ़िल्टर करने के लिए Elasticsearch क्वेरी।

उदाहरण:

{
  "index": "my-index",
  "query": {
    "bool": {
      "must": [
        { "term": { "status": "active" } },
        { "range": { "created_date": { "gte": "2025-01-01" } } }
      ]
    }
  }
}

15. टेम्पलेट्स प्राप्त करें

Elasticsearch से अनुक्रमणिका टेम्पलेट्स प्राप्त करें।

पैरामीटर:

• name (वैकल्पिक, स्ट्रिंग): विशिष्ट टेम्पलेट नाम जिसे प्राप्त करना है। यदि छोड़ा गया, तो सभी टेम्पलेट लौटाता है।

उदाहरण:

{
  "name": "logs-template"
}

16. उपनाम प्राप्त करें

Elasticsearch से अनुक्रमणिका उपनाम प्राप्त करें।

पैरामीटर:

• name (वैकल्पिक, स्ट्रिंग): विशिष्ट उपनाम नाम जिसे प्राप्त करना है। यदि छोड़ा गया, तो सभी उपनाम लौटाता है।

उदाहरण:

{
  "name": "logs-alias"
}

विकास

विकास मोड में चलाना

विकास के दौरान सर्वर को वॉच मोड में चलाने के लिए, उपयोग करें:

npm run dev

प्रोटोकॉल कार्यान्वयन

यह सर्वर मॉडल संदर्भ प्रोटोकॉल को लागू करता है ताकि LLM क्लाइंट्स और Elasticsearch के बीच मानकीकृत संचार को सुगम बनाया जा सके। यह विभिन्न Elasticsearch ऑपरेशन्स को करने के लिए MCP क्लाइंट्स द्वारा कॉल किए जाने वाले उपकरणों का एक व्यापक सेट प्रदान करता है।

नए उपकरण जोड़ना

सर्वर में एक नया उपकरण जोड़ने के लिए:

1. src/index.ts में MCP सर्वर के उपकरण पंजीकरण प्रारूप का उपयोग करके उपकरण को परिभाषित करें।
2. src/utils/elasticsearchService.ts में आवश्यक कार्यक्षमता लागू करें।
3. नए उपकरण को दस्तावेज़ित करने के लिए इस README को अपडेट करें।

अन्य MCP क्लाइंट्स

Octodet Elasticsearch MCP सर्वर का उपयोग किसी भी MCP-संगत क्लाइंट के साथ किया जा सकता है, जिसमें शामिल हैं:

• OpenAI का ChatGPT MCP प्लगइन्स के माध्यम से
• Anthropic का क्लॉड डेस्कटॉप
• VS कोड में क्लॉड
• MCP SDK का उपयोग करके कस्टम अनुप्रयोग

प्रोग्रामेटिक उपयोग

आप अपने Node.js अनुप्रयोगों में सर्वर का प्रोग्रामेटिक रूप से भी उपयोग कर सकते हैं:

import { createOctodetElasticsearchMcpServer } from "@octodet/elasticsearch-mcp";
import { CustomTransport } from "@modelcontextprotocol/sdk/server";

// Elasticsearch कनेक्शन कॉन्फ़िगर करें
const config = {
  url: "http://localhost:9200",
  apiKey: "your_api_key",
  version: "8",
};

// सर्वर बनाएँ और प्रारंभ करें
async function startServer() {
  const server = await createOctodetElasticsearchMcpServer(config);

  // अपने कस्टम ट्रांसपोर्ट से कनेक्ट करें
  const transport = new CustomTransport();
  await server.connect(transport);

  console.log("Elasticsearch MCP सर्वर प्रारंभ किया गया");
}

startServer().catch(console.error);

लाइसेंस

यह परियोजना MIT लाइसेंस के तहत लाइसेंस प्राप्त है - विवरण के लिए LICENSE फ़ाइल देखें।