এক্সপ্রেস থেকে ইলাস্টিক সার্চ ব্যবহার

curl -fsSL https://elastic.co/start-local | sh

docker exec -it es-local-dev bin/elasticsearch-reset-password -u elastic

curl -X POST "http://localhost:9200/blogs/_doc/" \
  -H "Content-Type: application/json" \
  -u elastic:YOUR_PASSWORD \
  -d '{
        "title": "Hello Elasticsearch",
        "description": "Getting started with Express API"
      }'

{"_index":"blogs","_id":"t5ADHJoBZAd1zomDCcC2","_version":1,"result":"created","_shards":{"total":1,"successful":1,"failed":0},"_seq_no":1,"_primary_term":1}%

curl -X GET "http://localhost:9200/blogs/_search?pretty" -u elastic:YOUR_PASSWORD

npm init -y
npm install express @elastic/elasticsearch dotenv

{
  "name": "elastic_search",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "echo \"Error: no test specified\" && exit 1",
    "dev": "node index.js"
  },
  "keywords": [],
  "author": "",
  "license": "ISC",
  "type": "module",
  "dependencies": {
    "@elastic/elasticsearch": "^8.19.1",
    "dotenv": "^17.2.3",
    "express": "^5.1.0"
  }
}

import express from "express";
import dotenv from "dotenv";
import client from "./elasticsearch.js";

dotenv.config();

const app = express();
app.use(express.json());

// Create index if not exists
async function ensureIndex(index) {
  const exists = await client.indices.exists({ index });
  if (!exists) {
    await client.indices.create({
      index,
      body: {
        mappings: {
          properties: {
            title: { type: "text" },
            description: { type: "text" },
            createdAt: { type: "date" },
          },
        },
      },
    });
    console.log(`✅ Created index: ${index}`);
  }
}

// Index a document
app.post("/api/index/:indexName", async (req, res) => {
  const { indexName } = req.params;
  try {
    await ensureIndex(indexName);
    const result = await client.index({
      index: indexName,
      document: { ...req.body, createdAt: new Date() },
    });

    await client.indices.refresh({ index: indexName });
    res.json({ id: result._id, result: "created" });
  } catch (err) {
    console.error(err.meta ? err.meta.body : err);
    res.status(500).json({ error: err.meta ? err.meta.body : err.message });
  }
});

// Search documents
app.get("/api/index/:indexName/search", async (req, res) => {
  const { indexName } = req.params;
  const q = req.query.q || "";
  try {
    const result = await client.search({
      index: indexName,
      query: {
        multi_match: {
          query: q,
          fields: ["title", "description"],
        },
      },
    });

    res.json(result.hits.hits.map((h) => ({ id: h._id, ...h._source })));
  } catch (err) {
    res.status(500).json({ error: err.meta ? err.meta.body : err.message });
  }
});

app.listen(process.env.PORT || 3000, () =>
  console.log(`🚀 Server running on port ${process.env.PORT || 3000}`)
);

import { Client } from "@elastic/elasticsearch";
import dotenv from "dotenv";
dotenv.config();

const client = new Client({
  node: process.env.ELASTIC_URL,
  auth: {
    username: process.env.ELASTIC_USER,
    password: process.env.ELASTIC_PASS,
  },
 
});

export default client;

ELASTIC_URL=http://127.0.0.1:9200
PORT=3000
ELASTIC_USER=elastic
ELASTIC_PASS=YOUR_PASSWORD

http://localhost:3000/api/index/blogs/search?q=hello

POST: http://localhost:3000/api/index/blogs
{
    "title": "Hello, world!", 
    "description": "This data inserted from Express api."
}

{
    "id": "uJANHJoBZAd1zomDF8Dj",
    "result": "created"
}