import requests
import time

EsHost = 'http://114.114.114.114'
EsPort = '9201'
# 填寫(xiě)保留多少天的數(shù)據(jù)，單位是秒
days = 12960000

DeleteIndexList = []
ret = requests.get("%s:%s/_cat/indices" % (EsHost, EsPort))

with open("index.txt", mode='w', encoding='utf-8') as f:
    f.write(ret.text)
    f.close()

with open("index.txt", mode='r', encoding='utf-8') as f1:
    for i in f1.readlines():
        if i.split()[2].startswith(".") or i.split()[2] == "fuzhou_surrounding" or i.split()[2] == "surrounding":
            pass
        else:
            mess = i.split()[2].split('-')
            CurrentTime = time.strftime("%Y-%m-%d", time.localtime())
            UnixCurrentTime = time.strptime(CurrentTime, '%Y-%m-%d')
            IndexTime = time.strptime(mess[2].replace('.', '-'), '%Y-%m-%d')
            if time.mktime(UnixCurrentTime) - time.mktime(IndexTime) > days:
                DeleteIndexList.append(i.split()[2])

# for i in DeleteIndexList:
#     print(i)

def requests_delete(EsHost, EsPort, EsIndex):
    delete_url = EsHost + ':' + EsPort + '/' + EsIndex  # 刪除的唯一標(biāo)識(shí)
    result = requests.delete(delete_url)
    return result.text

for i in DeleteIndexList:
    requests_delete(EsHost, EsPort, i)
    print('%s delete successful' % i)
    time.sleep(3)