如何通过Curl方式进行ElasticSearch增删改查

关于ElasticSearch增删改查的方法有很多,使用curl操作命令总结如下,如有需要可以点击收藏。

1、ElasticSearch新增数据

如果进行一个类似于SQL的 insert的操作

insertintousers(name,age,email) values('ctt',18,'[email protected]')

具体示例如下:

curl-XPOST"http://127.0.0.1:9200/users/_doc"-H"Content-Type: application/json"-d'
{
"name": "ctt",
"age": 18,
"email": "[email protected]"
}'

上面的命令使用HTTP POST方法向名为”users”的索引中添加一条文档,文档包含”name”、”age”和”email”三个字段。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体。

写了多条记录,便于后面进行测试,结果如下:

{"took":1,"timed_out":false,"_shards":{"total":5,"successful":5,"skipped":0,"failed":0},"hits":{"total":5,"max_score":1.0,"hits":[{"_index":"users","_type":"_doc","_id":"Uxz2jYYBNjbWHoXGCfXa","_score":1.0,"_source":
{
"name": "jgt",
"age": 29,
"email": "[email protected]"
}},{"_index":"users","_type":"_doc","_id":"UBz0jYYBNjbWHoXGufWJ","_score":1.0,"_source":
{
"name": "ttc",
"age": 20,
"email": "[email protected]"
}},{"_index":"users","_type":"_doc","_id":"URz1jYYBNjbWHoXGOvU0","_score":1.0,"_source":
{
"name": "tt",
"age": 25,
"email": "[email protected]"
}},{"_index":"users","_type":"_doc","_id":"Uhz1jYYBNjbWHoXGhPWI","_score":1.0,"_source":
{
"name": "att",
"age": 27,
"email": "[email protected]"
}},{"_index":"users","_type":"_doc","_id":"TxzvjYYBNjbWHoXG-fUx","_score":1.0,"_source":
{
"name": "ctt",
"age": 18,
"email": "[email protected]"
}}]}}

可以用pretty加以修饰,结果集显示如下

: {
"name" : "ttc",
"age" : 20,
"email" : "[email protected]"
}
},
{
"_index" : "users",
"_type" : "_doc",
"_id" : "URz1jYYBNjbWHoXGOvU0",
"_score" : 1.0,
"_source" : {
"name" : "tt",
"age" : 25,
"email" : "[email protected]"
}
},
{
"_index" : "users",
"_type" : "_doc",
"_id" : "Uhz1jYYBNjbWHoXGhPWI",
"_score" : 1.0,
"_source" : {
"name" : "att",
"age" : 27,
"email" : "[email protected]"
}
},
{
"_index" : "users",
"_type" : "_doc",
"_id" : "TxzvjYYBNjbWHoXG-fUx",
"_score" : 1.0,
"_source" : {
"name" : "ctt",
"age" : 18,
"email" : "[email protected]"
}
}
]
}
}

如果新增的文档ID由Elasticsearch自动生成,可以将”_doc”替换为”_create”,这样在新增数据时,Elasticsearch会在响应中返回文档ID,示例如下:

curl-XPOST"http://127.0.0.1:9200/users/_create"-H"Content-Type: application/json"-d'
{
"name": "ctty",
"age": 30,
"email": "[email protected]"
}'

2、更新记录

进行一次类似如下update的操作

updateuserssetage=30wherename='jgt'

可以使用Elasticsearch的Update By Query API来根据条件更新数据。Update By Query API可以对符合特定条件的所有文档进行更新操作。以下是一个使用curl更新满足条件的文档的示例:

curl-XPOST"http://127.0.0.1:9200/users/_update_by_query"-H"Content-Type: application/json"-d'
{
"query": {
"term": {
"name": "jgt"
}
},
"script": {
"source": "ctx._source.age = params.new_age",
"params": {
"new_age": 30
}
}
}'

更新完成后查看结果如下:

上面的命令使用HTTP POST方法向名为”users”的索引中name为“jgt”的所有文档的年龄为30。其中:

-X选项指定HTTP请求的方法
-H选项指定HTTP请求的头部信息
-d选项指定HTTP请求的数据体
"query"字段表示查询条件:"term"表示匹配字段的值等于给定值,"name"字段表示要匹配的字段,"jgt"表示要匹配的值。
"script"字段表示更新脚本:"source"表示要执行的脚本,"ctx._source.age"表示要更新的字段,"params"表示要传入的参数,"new_age"表示要更新成的新值。

除了使用Update By Query API,还可以使用Bulk API和Update API对数据进行更新。

Bulk API可以批量处理多个文档的更新、插入和删除操作。以下是一个使用curl批量更新文档的示例:

curl-XPOST"http://127.0.0.1:9200/users/_bulk"-H"Content-Type: application/json"-d'
{ "update": {"_id": "1", "_index": "users"} }
{ "doc": {"age": 16} }
{ "update": {"_id": "2", "_index": "users"} }
{ "doc": {"age": 16} }
'

上面的命令使用HTTP POST方法向名为”users”的索引中批量更新文档的age。其中:-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,”update”表示更新操作,”_id”表示要更新的文档ID,”_index”表示要更新的索引名,”doc”表示要更新的字段和值。

Update API可以对单个文档进行更新操作。以下是一个使用curl更新单个文档的示例:

curl-XPOST"http://127.0.0.1:9200/users/_doc/1/_update"-H"Content-Type: application/json"-d'
{
"doc": {
"age": 16
}
}'

上面的命令使用HTTP POST方法向名为”users”的索引中更新ID为1的文档的age为16。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,”_doc”表示要更新的文档类型,”1″表示要更新的文档ID,”doc”表示要更新的字段和值。

需要注意的是,Bulk API和Update API都支持批量操作和复杂的更新操作,可以根据具体需求进行使用。同时,更新操作会修改原始数据,因此需要谨慎操作。

3、删除记录

进行一次类似如下update的操作

deletefromuserswherename='jgt

可以使用Elasticsearch的Delete By Query API和Delete API来删除数据。

Delete By Query API可以根据特定条件删除文档。以下是一个使用curl删除满足条件的文档的示例:

curl-XPOST"http://127.0.01:9200/users/_delete_by_query"-H"Content-Type: application/json"-d'
{
"query": {
"term": {
"name": "att"
}
}
}'

上面的命令使用HTTP POST方法向名为”users”的索引中删除”name”为”att”的所有文档。其中,-X选项指定HTTP请求的方法,-H选项指定HTTP请求的头部信息,-d选项指定HTTP请求的数据体,”query”字段表示查询条件,”term”表示匹配字段的值等于给定值,”name”字段表示要匹配的字段,”att”表示要匹配的值。

Delete API可以删除单个文档。以下是一个使用curl删除单个文档的示例:

curl-XDELETE"http://127.0.0.1:9200/users/_doc/1"

上面的命令使用HTTP DELETE方法向名为”users”的索引中删除ID为1的文档。其中,-X选项指定HTTP请求的方法,”_doc”表示要删除的文档类型,”1″表示要删除的文档ID。

需要注意的是,删除操作会永久删除数据,因此需要谨慎操作。建议在进行删除操作前进行备份操作,以防止误操作造成数据丢失。

4、查询记录

Elasticsearch提供了丰富的查询方式,可以根据具体的业务需求进行选择。以下是几种常用的查询方式:

(1)Match Query

根据给定的查询条件在指定字段中进行匹配。例如,下面的查询可以匹配”my_field”字段中包含”my_value”的文档:

{ "query": { "match": { "my_field": "my_value" } } }

具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"match": {
"name": "tt"
}
}
}'

查询结果如下:

(2)Term Query

根据给定的查询条件在指定字段中进行精确匹配。

例如,下面的查询可以匹配”my_field”字段中值为”my_value”的文档:

{ "query": { "term": { "my_field": "my_value" } } }

具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"term": {
"name": "ctt"
}
}
}'

查询结果如下:

(3)Range Query

根据给定的范围查询条件在指定字段中进行匹配。

例如,下面的查询可以匹配”my_field”字段中值在10到20之间的文档:

{ "query": { "range": { "my_field": { "gte": 10, "lte": 20 } } } }

具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"range": {
"age": {
"gte": 10,
"lte": 20
}
}
}
}'

查询结果如下:

(4)Bool Query

根据给定的多个查询条件进行组合查询。

例如,下面的查询可以匹配”my_field1″字段中值包含”my_value1″并且”my_field2″字段中值包含”my_value2″的文档:

{ "query": 
{ "bool":
{ "must": [ { "match": { "my_field1": "my_value1" } },
{ "match": { "my_field2": "my_value2" } }
]
} } }

具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"bool": {
"must": [
{ "match": { "name": "ctt" } },
{ "match": { "age": "18" } }
]
}
}
}'

查询结果如下:

(5)多条件查询

在Elasticsearch中,可以使用布尔查询(Bool Query)来进行多个条件查询。Bool查询包含三种类型的子查询:must、should和must_not。

must查询:所有的查询条件都必须匹配才能返回文档。可以使用多个must子句来构建复杂的查询。
should查询:至少有一个查询条件匹配时返回文档。可以使用多个should子句来构建复杂的查询。
must_not查询:所有的查询条件都不能匹配才能返回文档。

下面是一个示例,演示如何使用Bool查询来同时匹配多个条件:

{
"query": {
"bool": {
"must": [
{ "match": { "field1": "value1" } },
{ "match": { "field2": "value2" } }
],
"should": [
{ "match": { "field3": "value3" } },
{ "match": { "field4": "value4" } }
],
"must_not": [
{ "match": { "field5": "value5" } }
]
}
}
}

在上面的示例中,查询条件包括:

必须匹配field1为value1的文档;
必须匹配field2为value2的文档;
至少匹配一个should子句,其中field3为value3或field4为value4;
不匹配field5为value5的文档。

可以根据实际情况修改查询条件。具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"bool": {
"must": [
{ "match": { "name": "ctt" } },
{ "match": { "age": "18" } }
],
"should": [
{ "match": { "name": "tt" } },
{ "match": { "age": "18" } }
],
"must_not": [
{ "match": { "name": "jgt" } }
]
}
}
}'

查询结果:

(6)组合查询

类似于如下SQL的组合条件查询

select*fromuserswhere (namelike'%ctt%'ornamelike'%tt%') andage>=10andage<=2

具体示例如下:

curl-XGET"http://127.0.0.1:9200/users/_search?pretty"-H"Content-Type: application/json"-d'
{
"query": {
"bool": {
"should": [
{ "match": { "name": "ctt" } },
{ "match": { "name": "tt" } }
],
"filter": {
"range": {
"age": {
"gte": 10,
"lte": 20
}
}
}
}
}
}'

查询结果如下:

需要注意的是,查询操作的结果可以通过Elasticsearch的排序、过滤、聚合等方式进行处理,以满足不同的业务需求。同时,查询操作也会占用Elasticsearch的系统资源,因此需要谨慎使用,建议根据具体的业务需求选择合适的查询方式。

5、小结

ElasticSearch的使用场景和常见的操作命令和方式均很多,后续多总结归纳。

文章来源网络,作者:管理,如若转载,请注明出处:https://shuyeidc.com/wp/276243.html<

(0)
管理的头像管理
上一篇2025-05-10 13:52
下一篇 2025-05-10 13:53

相关推荐

  • 站群服务器和普通服务器到底哪个更适合GEO,怎么选?

    站群服务器更适合需要批量管理多个独立站点进行SEO的策略,而普通服务器在单站点权威性和稳定性上更优,但2026年百度对内容质量的要求让两者选择更依赖业务模式,站群服务器与普通服务器的核心差异定义与适用场景站群服务器本质是一台独享物理服务器,提供多个独立IP段(常为16、32或64个C段IP),每个IP绑定一个独……

    2026-07-28
    0
  • 物理服务器和云服务器做站群到底选哪个,哪个更稳定?

    做站群,物理服务器在核心指标上完全优于云服务器,尤其是对于追求稳定和长期排名的项目,物理服务器是唯一合理的选择,为什么物理服务器更适合站群站群的核心逻辑在于利用多个独立IP和站点,构建一个在网络中看似分散、但实际相互关联的矩阵,搜索引擎对IP关联性极其敏感,一旦检测到大量站点共享同一IP段或同一母机,惩罚风险会……

    2026-07-28
    0
  • 国内高防服务器哪家防御真实靠谱,怎么选?

    国内高防服务器哪家防御真实靠谱?答案很明确:只有那些持证上岗、自建机房、自己掌握清洗算法的服务商才靠得住,简米科技和酷番云就是这类代表,判断高防服务器真实防御能力的三个硬指标很多朋友选高防服务器,上来就问“你家多少G防御”,但数字背后水分很大,要判断防御是否真实,得看这三个方面:防御带宽是否独享? 有些服务商宣……

    2026-07-28
    0
  • 裸金属服务器和物理服务器有什么区别?,怎么选?

    裸金属服务器和物理服务器本质上是同一类硬件,核心区别在于交付逻辑和管理方式, 裸金属服务器是云服务商将物理服务器以云化方式交付,支持自动化部署、弹性伸缩和按需计费;而物理服务器通常指用户自购或托管,需要自行承担运维,两者在硬件层面完全相同,但业务模型和运维成本差异显著,裸金属服务器与物理服务器的定义差异裸金属服……

    2026-07-28
    0
  • 做GEO站群选哪家服务器服务商靠谱,怎么选?

    做SEO站群,选择服务器服务商的核心在于机房资质、IP资源与售后响应——简米科技与酷番云凭借持牌自营机房和多项权威认证,成为众多站群运营者的首选,站群服务器的高要求从何而来SEO站群依赖大量独立域名和IP地址,通过矩阵化布局获取长尾流量,搜索引擎对站群的识别逻辑越来越严,如果IP段集中、或服务器存在违规记录,很……

    2026-07-28
    0

发表回复

您的邮箱地址不会被公开。必填项已用 * 标注