### 如何使用Python与Kibana和Elasticsearch进行交互 在Python中与Elasticsearch交互通常通过`elasticsearch-py`库实现。Kibana本身是一个可视化工具，不直接提供API供Python调用，但可以通过操作Elasticsearch中的数据间接影响Kibana的展示内容。 以下是一个完整的示例，展示如何使用Python与Elasticsearch进行交互，并创建索引、插入数据以及搜索数据[^5]： ```python from elasticsearch import Elasticsearch # 创建Elasticsearch客户端 es = Elasticsearch(["http://localhost:9200"]) # 检查连接状态 if not es.ping(): print("无法连接到Elasticsearch") else: print("成功连接到Elasticsearch") # 创建索引 index_name = "my-index" if not es.indices.exists(index=index_name): es.indices.create(index=index_name, ignore=400) print(f"索引 '{index_name}' 已创建") else: print(f"索引 '{index_name}' 已存在") # 插入文档 doc = {"name": "John Doe", "age": 30} es.index(index=index_name, id=1, body=doc) print("文档已插入") # 搜索文档 query = {"query": {"match": {"name": "John"}}} res = es.search(index=index_name, body=query) print(f"搜索结果包含 {res['hits']['total']['value']} 条记录") for hit in res['hits']['hits']: print(f"姓名: {hit['_source']['name']}, 年龄: {hit['_source']['age']}") ``` 上述代码展示了如何通过Python与Elasticsearch交互，包括创建索引、插入数据和搜索数据。这些操作会影响Kibana中的数据展示，因为Kibana的数据源来自Elasticsearch。 此外，如果需要更复杂的认证方式（如HTTPS或基本认证），可以参考以下代码片段[^1]： ```python import os from elasticsearch import Elasticsearch # 加载环境变量 load_dotenv() elastic_user = os.getenv('ES_USER') elastic_password = os.getenv('ES_PASSWORD') # 配置Elasticsearch客户端 url = f"https://{elastic_user}:{elastic_password}@localhost:9200" es = Elasticsearch(url, ca_certs="./http_ca.crt", verify_certs=True) # 检查连接状态 if es.ping(): print("成功连接到Elasticsearch") print(es.info()) else: print("无法连接到Elasticsearch") ``` 此代码片段展示了如何通过HTTPS和基本认证连接到Elasticsearch实例。 ### 注意事项 - 确保Elasticsearch和Kibana的版本一致，以避免兼容性问题[^3]。 - 如果需要实时日志可视化，可以结合Logstash将日志数据导入Elasticsearch，并通过Kibana展示[^2]。