Views
No views yet
1from elasticsearch import Elasticsearch
2
3# 创建Elasticsearch客户端
4es = Elasticsearch()
5
6# 创建索引
7def create_index(index_name):
8 # 创建索引映射
9 mapping = {
10 "mappings": {
11 "properties": {
12 "name": {"type": "text"},
13 "age": {"type": "integer"}
14 }
15 }
16 }
17
18 # 创建索引
19 es = es.create(index=index_name, body=mappinging)
20
21 # 打印结果
22 print("创建索引结果:")
23 print(res)
24
25# 删除索引
26def delete_index(index_name):
27 # 删除索引
28 res = es.delete(index=index_name)
29
30 # 打印结果
31 print("删除索引结果")
32 print(res)
33
34# 更新索引
35def update_index(index_name, doc_type, id, doc):
36 # 更新索引
37 res = es.update(index=index_name, doc_type=doc_type, id=id, body=doc)
38
39 # 打印结果
40 print("更新索引结果")
41 print(res)
42
43# 插入索引
44def insert_index(index_name, doc_type, id, doc):
45 # 插入索引
46 res = es.index(index=index_name, doc_type=doc_type, id=id, body=doc)
47
48 # 打印结果
49 print("插入索引结果")
50 print(res)
51
52# 查询索引
53def query_index(index_name, doc_type, id):
54 # 查询索引
55 res = es.get(index=index_name, doc_type=doc_type, id=id)
56
57 # 打印结果
58 print("查询索引结果")
59 print(res)
60
61# 创建索引
62create_index("my_index")
63
64# 查询索引
65query_index("my_index", "my_type", "1")
66
67# 插入索引
68insert_index("my_index", "my_type", "1", {"name": "John", "age": 30})
69
70# 更新索引
71update_index("my_index", "my_type", "1", {"doc": "John has updated his profile."})
72
73# 删除索引
74delete_index("my_index")1import os
2import datetime
3import xml.etree.ElementTree as ET
4import requests
5
6# 输入文件名和 目录
7file_name = "example.txt"
8directory = "/path/to/directory/"
9
10# 检查文件是否存在
11def check_file_exists(file_name, directory):
12 return os.path.isfile(os.path.join(directory, file_name))
13
14# 检查是否为8点
15def is_it_eight():
16 return datetime.datetime.now().hour == 8
17
18# 发送短信
19def send_sms(message):
20 # 这里需要你设置短信接口SM001的API接口和 �key
21 url = "http://sms.com/api/send"
22 data = {"message": message}
23 response = requests.post(url, data=data)
24 return response
25
26# 主程序
27def main():
28 # 检查文件是否存在
29 if check_file_exists(file_name, directory):
30 # 文件存在,不发送短信
31 print("文件存在,不发送短信")
32 else else:
33 # 文件不存在,发送短信
34 if is_it_eight():
35 # 在是8点,发送短信
36 message = f"文件{file_name}在{directory}目录下不存在,请检查"
37 send_sms(message)
38 else else:
39 # 不是8点,不发送短信
40 print("不是8点,不发送短信")
41
42if __name__ == "__main__":
43 main()