使用数据流
编辑使用数据流编辑
在您 设置数据流 后，您可以执行以下操作
向数据流添加文档编辑
response = client.index(
index: 'my-data-stream',
body: {
"@timestamp": '2099-03-08T11:06:07.000Z',
user: {
id: '8a4f500d'
},
message: 'Login successful'
}
)
puts response
POST /my-data-stream/_doc/
{
"@timestamp": "2099-03-08T11:06:07.000Z",
"user": {
"id": "8a4f500d"
},
"message": "Login successful"
}
您无法使用索引 API 的 PUT /<target>/_doc/<_id> 请求格式向数据流添加新文档。要指定文档 ID，请改用 PUT /<target>/_create/<_id> 格式。仅支持 op_type 为 create 的操作。
要使用单个请求添加多个文档，请使用 批量 API。仅支持 create 操作。
response = client.bulk(
index: 'my-data-stream',
refresh: true,
body: [
{
create: {}
},
{
"@timestamp": '2099-03-08T11:04:05.000Z',
user: {
id: 'vlb44hny'
},
message: 'Login attempt failed'
},
{
create: {}
},
{
"@timestamp": '2099-03-08T11:06:07.000Z',
user: {
id: '8a4f500d'
},
message: 'Login successful'
},
{
create: {}
},
{
"@timestamp": '2099-03-09T11:07:08.000Z',
user: {
id: 'l7gk7f82'
},
message: 'Logout successful'
}
]
)
puts response
PUT /my-data-stream/_bulk?refresh
{"create":{ }}
{ "@timestamp": "2099-03-08T11:04:05.000Z", "user": { "id": "vlb44hny" }, "message": "Login attempt failed" }
{"create":{ }}
{ "@timestamp": "2099-03-08T11:06:07.000Z", "user": { "id": "8a4f500d" }, "message": "Login successful" }
{"create":{ }}
{ "@timestamp": "2099-03-09T11:07:08.000Z", "user": { "id": "l7gk7f82" }, "message": "Logout successful" }
搜索数据流编辑
以下搜索 API 支持数据流
获取数据流的统计信息编辑
使用 数据流统计信息 API 获取一个或多个数据流的统计信息
response = client.indices.data_streams_stats( name: 'my-data-stream', human: true ) puts response
GET /_data_stream/my-data-stream/_stats?human=true
手动滚动数据流编辑
使用 滚动 API 手动 滚动 数据流。手动滚动时，您有两个选择
打开关闭的后台索引编辑
您无法搜索 关闭 的后台索引，即使通过搜索其数据流也不行。您也不能 更新 或 删除 关闭索引中的文档。
要重新打开关闭的后台索引，请直接向索引提交 打开索引 API 请求
response = client.indices.open( index: '.ds-my-data-stream-2099.03.07-000001' ) puts response
POST /.ds-my-data-stream-2099.03.07-000001/_open/
要重新打开数据流的所有关闭的后台索引，请向数据流提交打开索引 API 请求
response = client.indices.open( index: 'my-data-stream' ) puts response
POST /my-data-stream/_open/
使用数据流重新索引编辑
使用 重新索引 API 将文档从现有索引、别名或数据流复制到数据流。由于数据流是 仅追加 的，因此重新索引到数据流必须使用 op_type 为 create 的操作。重新索引不能更新数据流中的现有文档。
response = client.reindex(
body: {
source: {
index: 'archive'
},
dest: {
index: 'my-data-stream',
op_type: 'create'
}
}
)
puts response
POST /_reindex
{
"source": {
"index": "archive"
},
"dest": {
"index": "my-data-stream",
"op_type": "create"
}
}
通过查询更新数据流中的文档编辑
使用 通过查询更新 API 更新数据流中与提供的查询匹配的文档
response = client.update_by_query(
index: 'my-data-stream',
body: {
query: {
match: {
'user.id' => 'l7gk7f82'
}
},
script: {
source: 'ctx._source.user.id = params.new_id',
params: {
new_id: 'XgdX0NoX'
}
}
}
)
puts response
POST /my-data-stream/_update_by_query
{
"query": {
"match": {
"user.id": "l7gk7f82"
}
},
"script": {
"source": "ctx._source.user.id = params.new_id",
"params": {
"new_id": "XgdX0NoX"
}
}
}
通过查询删除数据流中的文档编辑
使用 通过查询删除 API 删除数据流中与提供的查询匹配的文档
response = client.delete_by_query(
index: 'my-data-stream',
body: {
query: {
match: {
'user.id' => 'vlb44hny'
}
}
}
)
puts response
POST /my-data-stream/_delete_by_query
{
"query": {
"match": {
"user.id": "vlb44hny"
}
}
}
更新或删除后台索引中的文档编辑
如果需要，您可以通过向包含文档的后台索引发送请求来更新或删除数据流中的文档。您需要
要获取此信息，请使用 搜索请求
response = client.search(
index: 'my-data-stream',
body: {
seq_no_primary_term: true,
query: {
match: {
'user.id' => 'yWIumJd7'
}
}
}
)
puts response
GET /my-data-stream/_search
{
"seq_no_primary_term": true,
"query": {
"match": {
"user.id": "yWIumJd7"
}
}
}
响应
{
"took": 20,
"timed_out": false,
"_shards": {
"total": 3,
"successful": 3,
"skipped": 0,
"failed": 0
},
"hits": {
"total": {
"value": 1,
"relation": "eq"
},
"max_score": 0.2876821,
"hits": [
{
"_index": ".ds-my-data-stream-2099.03.08-000003",
"_id": "bfspvnIBr7VVZlfp2lqX",
"_seq_no": 0,
"_primary_term": 1,
"_score": 0.2876821,
"_source": {
"@timestamp": "2099-03-08T11:06:07.000Z",
"user": {
"id": "yWIumJd7"
},
"message": "Login successful"
}
}
]
}
}
要更新文档，请使用带有有效的 if_seq_no 和 if_primary_term 参数的 索引 API 请求
PUT /.ds-my-data-stream-2099-03-08-000003/_doc/bfspvnIBr7VVZlfp2lqX?if_seq_no=0&if_primary_term=1
{
"@timestamp": "2099-03-08T11:06:07.000Z",
"user": {
"id": "8a4f500d"
},
"message": "Login successful"
}
要删除文档，请使用 删除 API
response = client.delete( index: '.ds-my-data-stream-2099.03.08-000003', id: 'bfspvnIBr7VVZlfp2lqX' ) puts response
DELETE /.ds-my-data-stream-2099.03.08-000003/_doc/bfspvnIBr7VVZlfp2lqX
要使用单个请求删除或更新多个文档，请使用 批量 API 的 delete、index 和 update 操作。对于 index 操作，请包含有效的 if_seq_no 和 if_primary_term 参数。
response = client.bulk(
refresh: true,
body: [
{
index: {
_index: '.ds-my-data-stream-2099.03.08-000003',
_id: 'bfspvnIBr7VVZlfp2lqX',
if_seq_no: 0,
if_primary_term: 1
}
},
{
"@timestamp": '2099-03-08T11:06:07.000Z',
user: {
id: '8a4f500d'
},
message: 'Login successful'
}
]
)
puts response
PUT /_bulk?refresh
{ "index": { "_index": ".ds-my-data-stream-2099.03.08-000003", "_id": "bfspvnIBr7VVZlfp2lqX", "if_seq_no": 0, "if_primary_term": 1 } }
{ "@timestamp": "2099-03-08T11:06:07.000Z", "user": { "id": "8a4f500d" }, "message": "Login successful" }