Elasticsearch：ES|QL 查询 TypeScript 类型（二）

在我之前的文章 “Elasticsearch：ES|QL 查询 TypeScript 类型（一）”，我们讲述了如何在 Nodejs 里对 ES|QL 进行查询。在今天的文章中，我们来使用一个完整的例子来进行详细描述。更多有关如何使用 Nodejs 来访问 Elasticsearch的知识，请参阅文章 “Elasticsearch：使用最新的 Nodejs client 8.x 来创建索引并搜索”。

在一下的演示中，我将使用 Elastic Stack 8.13.4 来进行展示。

安装

Elasticsearch 及 Kibana

如果你还没有安装好自己的 Elasticsearch 及 Kibana，请参考如下的链接来进行安装：

  • 如何在 Linux，MacOS 及 Windows 上进行安装 Elasticsearch
  • Kibana：如何在 Linux，MacOS 及 Windows上安装 Elastic 栈中的 Kibana

在安装的时候，我们选择 Elastic Stack 8.x 来进行安装。特别值得指出的是：ES|QL 只在 Elastic Stack 8.11 及以后得版本中才有。你需要下载 Elastic Stack 8.11 及以后得版本来进行安装。

在首次启动 Elasticsearch 的时候，我们可以看到如下的输出：

我们需要记下 Elasticsearch 超级用户 elastic 的密码。

我们还可以在安装 Elasticsearch 目录中找到 Elasticsearch 的访问证书：

$ pwd
/Users/liuxg/elastic/elasticsearch-8.13.4/config/certs
$ ls
http.p12      http_ca.crt   transport.p12

在上面，http_ca.crt 是我们需要用来访问 Elasticsearch 的证书。

Nodejs 依赖包

我们可以使用如下的命令来安装最新的 nodejs 客户端包：

yarn add @elastic/elasticsearch或者npm install @elastic/elasticsearch

我们可以通过如下的命令来查看安装的版本：

$ npm -v @elastic/elasticsearch
8.19.2

创建项目目录并拷贝证书

我们在电脑里创建一个目录，并拷贝相应的 Elasticsearch 访问证书到该目录下：

$ pwd
/Users/liuxg/nodejs/esql
$ cp ~/elastic/elasticsearch-8.13.4/config/certs/http_ca.crt .
$ ls http_ca.crt 
http_ca.crt

我们使用如下的命令来安装：

npm install --save-dev @types/node

创建一个叫做 esql.ts 的文件

touch esql.ts

我们使用如下的命令来安装 ts-node：

npm install -g ts-node typescript '@types/node'

在下面我们将使用如下的命令来运行代码：

ts-node esql.ts

展示

连接到 Elasticsearch

我们编辑 esql.ts 如下：

import { Client } from '@elastic/elasticsearch'
import * as fs from "fs";const client = new Client({node: 'https://localhost:9200',auth: {username: 'elastic',password: '=VnaMJck+DbYXpHR1Fch'},tls: {ca: fs.readFileSync('./http_ca.crt'),rejectUnauthorized: false}})client.info().then((response) => console.log(JSON.stringify(response))).catch((error) => console.error(JSON.stringify(error)));

在上面，我们使用超级账号 elastic 来进行连接。我们使用证书来访问自签名证书的集群。你需要根据自己的 Elasticsearch 配置修改上面的代码。更多关于如何访问 Elasticsearch 的知识，请阅读文章 “Elasticsearch：使用最新的 Nodejs client 8.x 来创建索引并搜索”。 运行上面的代码，返回：

$ ts-node esql.ts 
{"name":"liuxgm.local","cluster_name":"elasticsearch","cluster_uuid":"JXoZ_Xu-QnasteO4AWnVvQ","version":{"number":"8.13.4","build_flavor":"default","build_type":"tar","build_hash":"da95df118650b55a500dcc181889ac35c6d8da7c","build_date":"2024-05-06T22:04:45.107454559Z","build_snapshot":false,"lucene_version":"9.10.0","minimum_wire_compatibility_version":"7.17.0","minimum_index_compatibility_version":"7.0.0"},"tagline":"You Know, for Search"}

写入数据

esql.ts

import { Client } from '@elastic/elasticsearch'
import * as fs from "fs";const client = new Client({node: 'https://localhost:9200',auth: {username: 'elastic',password: '=VnaMJck+DbYXpHR1Fch'},tls: {ca: fs.readFileSync('./http_ca.crt'),rejectUnauthorized: false}})client.info().then((response) => console.log(JSON.stringify(response))).catch((error) => console.error(JSON.stringify(error))); async function run () {// Lets index some data into Elasticsearchawait client.indices.exists({index: "books"}).then(function (exists) {if(exists) {console.log("the index already existed")} else {console.log("the index has not been createdyet")client.helpers.bulk({datasource: [{ name: "Revelation Space", author: "Alastair Reynolds", release_date: "2000-03-15", page_count: 585 },{ name: "1984", author: "George Orwell", release_date: "1985-06-01", page_count: 328 },{ name: "Fahrenheit 451", author: "Ray Bradbury", release_date: "1953-10-15", page_count: 227 },{ name: "Brave New World", author: "Aldous Huxley", release_date: "1932-06-01", page_count: 268 },],onDocument(_doc) {return { index: { _index: "books" } }},})}})
}run().catch(console.log)

在运行完上面的代码后，我们可以在 Kibana 中进行查看：

对数据进行 ES|QL 查询

    const response = await client.esql.query({ query: 'FROM books' })console.log(response)

完整的代码为：

esql.ts

import { Client } from '@elastic/elasticsearch'
import * as fs from "fs";const client = new Client({node: 'https://localhost:9200',auth: {username: 'elastic',password: '=VnaMJck+DbYXpHR1Fch'},tls: {ca: fs.readFileSync('./http_ca.crt'),rejectUnauthorized: false}})client.info().then((response) => console.log(JSON.stringify(response))).catch((error) => console.error(JSON.stringify(error))); async function run () {// Lets index some data into Elasticsearchawait client.indices.exists({index: "books"}).then(function (exists) {if(exists) {console.log("the index already existed")} else {console.log("the index has not been createdyet")client.helpers.bulk({datasource: [{ name: "Revelation Space", author: "Alastair Reynolds", release_date: "2000-03-15", page_count: 585 },{ name: "1984", author: "George Orwell", release_date: "1985-06-01", page_count: 328 },{ name: "Fahrenheit 451", author: "Ray Bradbury", release_date: "1953-10-15", page_count: 227 },{ name: "Brave New World", author: "Aldous Huxley", release_date: "1932-06-01", page_count: 268 },],onDocument(_doc) {return { index: { _index: "books" } }},})}})const response = await client.esql.query({ query: 'FROM books' })console.log(response)
}run().catch(console.log)

上面代码的完整响应为：

$ ts-node esql.ts 
the index already existed
{"name":"liuxgm.local","cluster_name":"elasticsearch","cluster_uuid":"JXoZ_Xu-QnasteO4AWnVvQ","version":{"number":"8.13.4","build_flavor":"default","build_type":"tar","build_hash":"da95df118650b55a500dcc181889ac35c6d8da7c","build_date":"2024-05-06T22:04:45.107454559Z","build_snapshot":false,"lucene_version":"9.10.0","minimum_wire_compatibility_version":"7.17.0","minimum_index_compatibility_version":"7.0.0"},"tagline":"You Know, for Search"}
{columns: [{ name: 'author', type: 'text' },{ name: 'author.keyword', type: 'keyword' },{ name: 'name', type: 'text' },{ name: 'name.keyword', type: 'keyword' },{ name: 'page_count', type: 'long' },{ name: 'release_date', type: 'date' }],values: [['Alastair Reynolds','Alastair Reynolds','Revelation Space','Revelation Space',585,'2000-03-15T00:00:00.000Z'],['George Orwell','George Orwell','1984','1984',328,'1985-06-01T00:00:00.000Z'],['Ray Bradbury','Ray Bradbury','Fahrenheit 451','Fahrenheit 451',227,'1953-10-15T00:00:00.000Z'],['Aldous Huxley','Aldous Huxley','Brave New World','Brave New World',268,'1932-06-01T00:00:00.000Z']]
}

将每行返回为值数组是一个简单的默认设置，在许多情况下很有用。不过，如果你想要一个记录数组（JavaScript 应用程序中的标准结构），则需要额外的努力来转换数据。

幸运的是，在 8.14.0 中，JavaScript 客户端将包含一个新的 ES|QL 助手来为你执行此操作：

const { records } = await client.helpers.esql({ query: 'FROM books' }).toRecords()/*
Returns:
[{ name: "Revelation Space", author: "Alastair Reynolds", release_date: "2000-03-15", page_count: 585 },{ name: "1984", author: "George Orwell", release_date: "1985-06-01", page_count: 328 },{ name: "Fahrenheit 451", author: "Ray Bradbury", release_date: "1953-10-15", page_count: 227 },{ name: "Brave New World", author: "Aldous Huxley", release_date: "1932-06-01", page_count: 268 },
]
*/

截止目前为止，8.14 还没有发布。期待在正式发布后，我们再重新尝试。

更多关于 ES|QL 的查询，请详细阅读文章 “Elasticsearch：ES|QL 动手实践”。

在文章的最后，我们可以来完成另外一个查询。我们使用 Kibana 来进行查询：

POST _query?format=txt
{"query": """FROM books| WHERE release_date > "1985-06-01"| LIMIT 5"""
}

我们使用 Nodejs 来进行查询：

    const query = 'FROM books | WHERE release_date > "1985-06-01" | LIMIT 5'const response1 = await client.esql.query({ query: query })console.log(response1)

esql.ts

import { Client } from '@elastic/elasticsearch'
import * as fs from "fs";const client = new Client({node: 'https://localhost:9200',auth: {username: 'elastic',password: '=VnaMJck+DbYXpHR1Fch'},tls: {ca: fs.readFileSync('./http_ca.crt'),rejectUnauthorized: false}})client.info().then((response) => console.log(JSON.stringify(response))).catch((error) => console.error(JSON.stringify(error))); async function run () {// Lets index some data into Elasticsearchawait client.indices.exists({index: "books"}).then(function (exists) {if(exists) {console.log("the index already existed")} else {console.log("the index has not been createdyet")client.helpers.bulk({datasource: [{ name: "Revelation Space", author: "Alastair Reynolds", release_date: "2000-03-15", page_count: 585 },{ name: "1984", author: "George Orwell", release_date: "1985-06-01", page_count: 328 },{ name: "Fahrenheit 451", author: "Ray Bradbury", release_date: "1953-10-15", page_count: 227 },{ name: "Brave New World", author: "Aldous Huxley", release_date: "1932-06-01", page_count: 268 },],onDocument(_doc) {return { index: { _index: "books" } }},})}})const response = await client.esql.query({ query: 'FROM books' })console.log(response)const query = 'FROM books | WHERE release_date > "1985-06-01" | LIMIT 5'const response1 = await client.esql.query({ query: query })console.log(response1)
}run().catch(console.log)

上面最后一个查询的结果为：

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/diannao/24735.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

JavaScript中的 和 || 区别

JavaScript中的 和 || 区别

在 JavaScript 中，&& 操作符被称为逻辑与操作符。当使用 && 操作符连接两个表达式时，它会首先计算左侧的表达式： 如果左侧的表达式为 false 或者可以转换为 false 的值（如 null、undefined、0、“” 空字符串或 …
阅读更多...
初入阿里云，上手走一波

初入阿里云，上手走一波

初入阿里云，上手走一波 一阶：ECSMysqlDMS安装Mysql初始化MysqlMysql操作DMS管理Mysql 二阶：ECSOSS远程连接ECSOSS控制台其他图片服务 三阶：更多搭配操作 可以说个人在日常使用过程中，操作最多的阿里云产品就是阿里云服…
阅读更多...
全身控制（Whole-Body Control，WBC）简化版

全身控制（Whole-Body Control，WBC）简化版

全身控制（Whole-Body Control，WBC）概述 WBC是一种集成了多种控制策略的方法，旨在同时控制人形机器人的多个自由度（DOF），以实现复杂的运动和任务。WBC通常通过优化来解决，同时考虑到…
阅读更多...
Python爬虫实战：从入门到精通

Python爬虫实战：从入门到精通

网络爬虫，又称为网络蜘蛛或爬虫，是一种自动浏览网页的程序，用于从互联网上收集信息。Python由于其简洁的语法和强大的库支持，成为开发网络爬虫的首选语言。 环境准备 Python安装 必要的库：requests, BeautifulSoup, Sc…
阅读更多...
使用 LLaMA-Factory 实现对大模型函数调用功能

使用 LLaMA-Factory 实现对大模型函数调用功能

节前，我们星球组织了一场算法岗技术&面试讨论会，邀请了一些互联网大厂朋友、参加社招和校招面试的同学。 针对算法岗技术趋势、大模型落地项目经验分享、新手如何入门算法岗、该如何准备、面试常考点分享等热门话题进行了深入的讨论。 合集&#x…
阅读更多...
现代密码学-认证、消息认证码

现代密码学-认证、消息认证码

什么是单向散列函数 单向散列函数（one way hash function）：一个输入：消息（message）,一个固定长度的输出(散列值，hash value),根据散列值检查消息完整性(integrity) 单向散列函数也称为消息摘要…
阅读更多...
linux中创建sftp

linux中创建sftp

前言：每次创建sftp的时候总是查一堆文档，不是有的步骤不对，就是缺失步骤，索性自己写一份以供后续方便使用。 一、添加用户组sftp --> groupadd sftp ●查看用户组是否创建成功 --> cat /etc/group 二、创建用户&#xf…
阅读更多...
Docker大学生看了都会系列（七、Dokcerfile详解）

Docker大学生看了都会系列（七、Dokcerfile详解）

系列文章目录 第一章 Docker介绍 第二章 2.1 Mac通过Homebrew安装Docker 第二章 2.2 CentOS安装Docker 第三章 Docker常用命令 第四章 常用命令实战 第五章 Docker镜像详解 第六章 Docker容器数据卷 第七章 Dockerfile详解 第八章 Dokcerfile部署go项目 文章目录 一、Dockerfil…
阅读更多...
图形化红队行动辅助平台Viper使用记录

图形化红队行动辅助平台Viper使用记录

图形化红队行动辅助平台Viper使用记录 简介 Viper(炫彩蛇)是一款图形化内网渗透工具,将内网渗透过程中常用的战术及技术进行模块化及武器化. Viper(炫彩蛇)集成杀软绕过,内网隧道,文件管理,命令行等基础功能. Viper(炫彩蛇)当前已集成70个模块,覆盖初始访问/持久化/权限提升/…
阅读更多...
Python 中的字符串、列表、元组和字典数据类型的特点和使用场景

Python 中的字符串、列表、元组和字典数据类型的特点和使用场景

字符串（str）是一种不可变的序列类型，由字符组成。它的特点是： 可以使用单引号或双引号来定义字符串。字符串中的字符是按照索引进行访问的，索引从0开始。字符串可以进行切片操作，获取部分子串。字符串可以…
阅读更多...
【数据结构】初识数据结构之复杂度与链表

【数据结构】初识数据结构之复杂度与链表

【数据结构】初识数据结构之复杂度与链表 🔥个人主页：大白的编程日记 🔥专栏：C语言学习之路 文章目录 【数据结构】初识数据结构之复杂度与链表前言一.数据结构和算法1.1数据结构1.2算法1.3数据结构和算法的重要性 二.时间与空间…
阅读更多...
【FPGA】arm数据总线和axi数据总线有什么异同点？

【FPGA】arm数据总线和axi数据总线有什么异同点？

ARM数据总线和AXI数据总线在概念和应用上有一些异同点： 相同点 功能目的：两者都是用于处理器与外部设备或内存之间传输数据的通道。设计原则：它们都遵循一些设计原则，以确保数据传输的可靠性和效率。 异同点 架构级别&#xff…
阅读更多...
Elasticsearch 认证模拟题 - 13

Elasticsearch 认证模拟题 - 13

一、题目 集群中有索引 task3，用 oa、OA、Oa、oA 查询结构是 4 条，使用 dingding 的查询结果是 1 条。通过 reindex 索引 task3 为 task3_new，能够使 task3_new 满足以下查询条件。 使用 oa、OA、Oa、oA、0A、dingding 查询都能够返回 6 条…
阅读更多...
【纯血鸿蒙】——自适应布局如何实现？

【纯血鸿蒙】——自适应布局如何实现？

界面级一多能力有 2 类： 自适应布局: 略微调整界面结构 响应式布局：比较大的界面调整 本文章先主要讲解自适应布局，响应式布局再后面文章再细讲。话不多说，开始了。 自适应布局 针对常见的开发场景，方舟开发框架提…
阅读更多...
React Native 快速Demo（1）

React Native 快速Demo（1）

为了快速实现一个项目雏型（prototype）demo并提交给他们确认，可以按照以下步骤进行： 1. 环境设置 1.1 安装开发工具 安装Node.js和npm：用于管理项目依赖。 sudo apt install nodejs sudo apt install npm安装React Na…
阅读更多...
QT系列教程(10) QTextEdit学习

QT系列教程(10) QTextEdit学习

简介 QTextEdit是文本编辑器，支持富文本功能。接下来我们创建一个Qt Application 应用，然后在ui中添加一个QTextEdit插件。 运行程序后，可以在QTextEdit中输入任何文字也包括富文本。 文本块 我们在MainWindow的ui文件中添加了textedit插件…
阅读更多...
24年江苏省教资认定报名照片要求

24年江苏省教资认定报名照片要求

24年江苏省教资认定报名照片要求，速速查收！
阅读更多...
Python代码——压缩整个文件夹

Python代码——压缩整个文件夹

使用 Python 的 zipfile 模块来创建一个压缩文件夹。 下面是一个示例代码，展示了如何将一个文件夹中的所有文件和子文件夹压缩成一个 ZIP 文件： import os import zipfiledef zip_folder(folder_path, output_path):# 创建一个 ZipFile 对象&#xff0…
阅读更多...
蓝屏绿屏黑屏？别急，有它们仨【送源码】

蓝屏绿屏黑屏？别急，有它们仨【送源码】

使用Windows系统的电脑时，可能会碰到各种问题，导致系统无法正常使用。 这些问题都有一个统一的专业叫法就是bug！ 系统一旦出现bug，最明显的特点就是， ①电脑蓝屏 电脑蓝屏是最经典的，从XP时代一直延续到…
阅读更多...
STM32项目分享：智能台灯系统

STM32项目分享：智能台灯系统

目录 一、前言 二、项目简介 1.功能详解 2.主要器件 三、原理图设计 四、PCB硬件设计 1.PCB图 2.PCB板及元器件图 五、程序设计 六、实验效果 七、资料内容 项目分享 一、前言 项目成品图片： 哔哩哔哩视频链接： https://www.bilibili.c…
阅读更多...
最新文章

Copyright @ 2022~2023