写一个脚本删除Elasticsearch中30天前的数据

当然，下面是一个可以用来删除Elasticsearch中30天前数据的脚本:

from datetime import datetime, timedelta
from elasticsearch import Elasticsearch

# 连接 Elasticsearch
es = Elasticsearch(['localhost'])

# 设置要删除的索引名
index_name = 'my_index'

# 获取30天前的日期
thirty_days_ago = datetime.now() - timedelta(days=30)

# 构建查询语句
query = {
  "query": {
    "range": {
      "@timestamp": {
        "lt": thirty_days_ago.strftime("%Y-%m-%dT%H:%M:%S.%fZ")
      }
    }
  }
}

# 执行删除操作
res = es.delete_by_query(index=index_name, body=query)

print(res)

需要注意的是，上面的代码使用了 Elasticsearch 的 delete_by_query API，这个 API 可能会对 Elasticsearch 集群造成较大的压力，请谨慎使用。另外，删除数据是一个不可逆的操作，请务必谨慎操作。

相关问题

用shell写一个删除Elasticsearch中30天前的数据

可以使用以下的shell脚本删除Elasticsearch中30天前的数据：

#!/bin/bash

# 设置要删除的索引名称，这里假设为"my_index"
index_name="my_index"

# 获取当前日期30天前的日期
delete_before_date=$(date -d "30 days ago" +"%Y.%m.%d")

# 构造要删除的索引名称，格式为"{索引名称}-{日期}"
delete_index_name="$index_name-$delete_before_date"

# 使用curl命令发送HTTP DELETE请求，删除指定索引
curl -X DELETE "http://localhost:9200/$delete_index_name"

解释一下上面的脚本：

- 第一行声明了脚本使用的shell解释器为bash。
- 第三行设置要删除的索引名称，这里假设为"my_index"，你需要将其替换为你实际使用的索引名称。
- 第六行使用date命令获取当前日期30天前的日期，保存到delete_before_date变量中。
- 第九行构造要删除的索引名称，格式为"{索引名称}-{日期}"，保存到delete_index_name变量中。
- 第十二行使用curl命令发送HTTP DELETE请求，删除指定索引。这里假设Elasticsearch运行在本地，监听端口为9200，你需要将其替换为你实际使用的Elasticsearch地址。

你可以将以上脚本保存到一个文件中，例如"delete_es_index.sh"，然后使用命令"sh delete_es_index.sh"来运行它。如果你需要定期执行该脚本，可以将其加入到系统的定时任务中。

帮我写一个删除elasticsearch三十天外索引数据的shell脚本

当然，以下是一个删除Elasticsearch中三十天外索引数据的Shell脚本：

#!/bin/bash

# 设置Elasticsearch的主机名、端口和索引的前缀
ES_HOST="localhost"
ES_PORT="9200"
INDEX_PREFIX="my-index-"

# 计算30天前的时间戳
CURRENT_TIME=$(date +%s)
DELETE_BEFORE=$(expr $CURRENT_TIME - 2592000)

# 获取所有符合条件的索引名称
INDICES=$(curl -s -XGET "http://${ES_HOST}:${ES_PORT}/_cat/indices/${INDEX_PREFIX}*?h=index" | grep "${INDEX_PREFIX}" | awk '{print $1}')

# 循环遍历所有符合条件的索引，并删除早于30天的索引
for INDEX in $INDICES
do
  INDEX_DATE=$(echo $INDEX | awk -F"${INDEX_PREFIX}" '{print $2}')
  INDEX_TIME=$(date -d"${INDEX_DATE}" +%s)

  if [ $INDEX_TIME -lt $DELETE_BEFORE ]; then
    echo "Deleting index ${INDEX}..."
    curl -XDELETE "http://${ES_HOST}:${ES_PORT}/${INDEX}"
  fi
done

这个脚本首先定义了Elasticsearch的主机名、端口和索引前缀。然后，它计算了30天前的时间戳，并使用`curl`命令获取所有符合条件的索引名称。最后，它循环遍历所有符合条件的索引，并删除早于30天的索引。在循环中，它首先计算每个索引的日期，并将其转换为时间戳。如果索引时间戳早于删除时间戳，它将使用`curl`命令删除该索引。

请注意，这个脚本假设索引名称的格式为`my-index-YYYY.MM.DD`，其中`YYYY`是四位数的年份，`MM`是两位数的月份，`DD`是两位数的日期。如果您的索引名称不是这个格式，您需要相应地修改脚本。