创建一个docker网络
docker network create elastic
然后拉elasticsearch 的docker 容器
docker pull docker.elastic.co/elasticsearch/elasticsearch:8.10.2
运行容器
docker run --name es01 --net elastic -p 9200:9200 -it -m 1GB docker.elastic.co/elasticsearch/elasticsearch:8.10.2
如果遇到报错Elasticsearch exited unexpectedly, with exit code 78
,在终端运行sudo sysctl -w vm.max_map_count=262144
然后删掉刚才的镜像,重新运行容器。(这个设置重启后会失效,可以在/etc/sysctl.conf
以设置使其永久有效。)
成功运行终端会弹出很多信息,然后最后会给出密码等,如下
记得保存密码,可以将密码加到环境变量里export ELASTIC_PASSWORD="your_password"
,他只会弹出一次。如果忘了也可以重置密码
docker exec -it es01 /usr/share/elasticsearch/bin/elasticsearch-reset-password -u elastic
docker exec -it es01 /usr/share/elasticsearch/bin/elasticsearch-create-enrollment-token -s kibana
把证书从容器中复制一份
docker cp es01:/usr/share/elasticsearch/config/certs/http_ca.crt .
然后运行命令查看restful api是否正常运行
curl --cacert http_ca.crt -u elastic:$ELASTIC_PASSWORD https://localhost:9200
如果看到类似下图的信息就成功了
运行下面的代码,password改成你自己的代码。
from elasticsearch import AsyncElasticsearch
import ssl
import asyncio
ssl_context = ssl.create_default_context(cafile='info/http_ca.crt')
es = AsyncElasticsearch(
['https://localhost:9200'],
http_auth=('elastic', 'password'),
scheme="https",
ssl_context=ssl_context
)
async def main():
info = await es.info()
print(info)
await es.close()
# 运行主函数
asyncio.run(main())
看到类似下面的输出代表运行成功