Nodejs Nestjs Elasticsearch插件@nestjs/elasticsearch的使用

Nodejs Nestjs Elasticsearch插件@nestjs/elasticsearch的使用
在NestJS中使用[@nestjs](/user/nestjs)/elasticsearch插件来与Elasticsearch进行交互是一个常见的需求。以下是如何安装和配置这个插件，以及如何使用它来执行基本的CRUD操作。

1. 安装必要的依赖

首先，你需要安装[@nestjs](/user/nestjs)/elasticsearch和elasticsearch库：

npm install [@nestjs](/user/nestjs)/elasticsearch elasticsearch

2. 配置模块

接下来，在你的NestJS应用中配置ElasticsearchModule。你可以在一个全局模块（如AppModule）中进行配置，或者在特定的服务中进行局部配置。

import { Module } from '[@nestjs](/user/nestjs)/common';
import { ElasticsearchModule } from '[@nestjs](/user/nestjs)/elasticsearch';

@Module({
  imports: [
    ElasticsearchModule.register({
      node: 'http://localhost:9200', // 你的Elasticsearch服务器地址
    }),
  ],
})
export class AppModule {}

3. 使用ElasticsearchClient

在你的服务中注入ElasticsearchService来访问Elasticsearch客户端：

import { Injectable } from '[@nestjs](/user/nestjs)/common';
import { ElasticsearchService } from '[@nestjs](/user/nestjs)/elasticsearch';

@Injectable()
export class AppService {
  constructor(private readonly elasticSearchService: ElasticsearchService) {}

  async createDocument(index: string, document: any): Promise<any> {
    return await this.elasticSearchService.index({
      index,
      body: document,
    });
  }

  async getDocument(index: string, id: string): Promise<any> {
    return await this.elasticSearchService.get({
      index,
      id,
    });
  }

  async updateDocument(index: string, id: string, document: any): Promise<any> {
    return await this.elasticSearchService.update({
      index,
      id,
      body: { doc: document },
    });
  }

  async deleteDocument(index: string, id: string): Promise<any> {
    return await this.elasticSearchService.delete({
      index,
      id,
    });
  }
}

4. 创建控制器

最后，创建一个控制器来暴露这些方法：

import { Controller, Get, Post, Body, Param } from '[@nestjs](/user/nestjs)/common';
import { AppService } from './app.service';

@Controller()
export class AppController {
  constructor(private readonly appService: AppService) {}

  @Post('create')
  async create(@Body() body: any) {
    const { index, document } = body;
    return this.appService.createDocument(index, document);
  }

  @Get('get/:index/:id')
  async get(@Param('index') index: string, @Param('id') id: string) {
    return this.appService.getDocument(index, id);
  }

  @Post('update')
  async update(@Body() body: any) {
    const { index, id, document } = body;
    return this.appService.updateDocument(index, id, document);
  }

  @Delete('delete/:index/:id')
  async delete(@Param('index') index: string, @Param('id') id: string) {
    return this.appService.deleteDocument(index, id);
  }
}

以上步骤展示了如何在NestJS中设置和使用[@nestjs](/user/nestjs)/elasticsearch插件。你可以根据需要调整索引名称、文档内容等。确保你的Elasticsearch实例正在运行，并且可以通过指定的地址访问。


3 回复

当然，没问题！想象一下，你正在一个魔法森林里探险，而Elasticsearch就是你的神奇地图。使用@nestjs/elasticsearch插件，就像是给你的魔法杖添加了一个新咒语！

首先，确保你的项目中安装了这个插件：

npm install @nestjs/elasticsearch elasticsearch

然后，在你的模块文件（比如app.module.ts）中引入它：

import { Module } from '@nestjs/common';
import { ElasticsearchModule } from '@nestjs/elasticsearch';

@Module({
  imports: [
    ElasticsearchModule.register({
      node: 'http://localhost:9200',
    }),
  ],
})
export class AppModule {}

现在，你可以像这样在一个服务中使用它：

import { Injectable } from '@nestjs/common';
import { ElasticsearchService } from '@nestjs/elasticsearch';

@Injectable()
export class SearchService {
  constructor(private readonly elasticsearchService: ElasticsearchService) {}

  async search(query: string) {
    const result = await this.elasticsearchService.search({
      index: 'your_index_name',
      body: {
        query: {
          match: {
            _all: query,
          },
        },
      },
    });
    return result;
  }
}

这样，你就能够像一位真正的森林探险家一样，轻松地搜索到你需要的信息啦！


当然可以。@nestjs/elasticsearch 是一个用于 NestJS 的 Elasticsearch 客户端库。以下是如何在你的 NestJS 应用程序中使用这个插件的一些基本步骤和示例代码。

1. 安装依赖

首先，你需要安装 @nestjs/elasticsearch 和 elasticsearch 包：

npm install @nestjs/elasticsearch elasticsearch

2. 配置模块

接下来，在你的 NestJS 模块中导入 ElasticsearchModule 并配置连接选项。

import { Module } from '@nestjs/common';
import { ElasticsearchModule } from '@nestjs/elasticsearch';

@Module({
  imports: [
    ElasticsearchModule.register({
      node: 'http://localhost:9200', // Elasticsearch 的地址
    }),
  ],
})
export class AppModule {}

3. 创建服务

然后，你可以创建一个服务来与 Elasticsearch 进行交互。

import { Injectable } from '@nestjs/common';
import { Client, ElasticsearchService } from '@nestjs/elasticsearch';

@Injectable()
export class ElasticsearchService {
  constructor(private readonly esService: ElasticsearchService) {}

  async search(query: any) {
    const result = await this.esService.search(query);
    return result.body;
  }

  async index(index: string, body: any) {
    const result = await this.esService.index({ index, body });
    return result.body;
  }
}

4. 使用服务

最后，你可以在控制器或其他服务中注入并使用 ElasticsearchService。

import { Controller, Get, Post, Body } from '@nestjs/common';
import { ElasticsearchService } from './elasticsearch.service';

@Controller('documents')
export class DocumentsController {
  constructor(private readonly esService: ElasticsearchService) {}

  @Post()
  async create(@Body() document: any) {
    const res = await this.esService.index('documents', document);
    return res;
  }

  @Get()
  async search(@Body() query: any) {
    const res = await this.esService.search(query);
    return res;
  }
}

5. 测试

现在你可以启动你的 NestJS 应用，并使用 Postman 或其他工具发送请求来测试你的 API。

例如，创建一个文档：

POST http://localhost:3000/documents
{
  "title": "NestJS Elasticsearch",
  "content": "This is a sample document."
}

搜索文档：

POST http://localhost:3000/documents
{
  "query": {
    "match": {
      "title": "NestJS"
    }
  }
}

这样，你就成功地在 NestJS 应用中集成了 Elasticsearch 功能。希望这对你有所帮助！

@nestjs/elasticsearch 是 NestJS 框架中用于与 Elasticsearch 进行交互的官方插件。首先安装此插件和必要的依赖：

npm install @nestjs/elasticsearch elasticsearch

接着，在模块中导入 ElasticsearchModule 并配置连接信息：

import { Module } from '@nestjs/common';
import { ElasticsearchModule } from '@nestjs/elasticsearch';

@Module({
  imports: [
    ElasticsearchModule.forRoot({
      node: 'http://localhost:9200',
    }),
  ],
})
export class ApplicationModule {}

然后可以在服务中注入 ElasticsearchService 来执行查询操作：

import { Injectable } from '@nestjs/common';
import { ElasticsearchService } from '@nestjs/elasticsearch';

@Injectable()
export class AppService {
  constructor(private readonly elasticsearchService: ElasticsearchService) {}

  async search(query: string) {
    return this.elasticsearchService.search({
      index: 'your_index_name',
      body: {
        query: {
          match: {
            _all: query,
          },
        },
      },
    });
  }
}

以上就是一个基本的 NestJS 项目中使用 @nestjs/elasticsearch 插件的例子。

回到顶部