python向elasticsearch传输文件代码

以下是Python向Elasticsearch传输文件的代码示例：

from elasticsearch import Elasticsearch
import base64

# 连接到 Elasticsearch
es = Elasticsearch(['http://localhost:9200'])

# 读取要传输的文件
with open('file.txt', 'rb') as f:
    file_content = f.read()

# 将文件内容进行 base64 编码
file_encoded = base64.b64encode(file_content).decode('utf-8')

# 定义要传输的数据
data = {
    'file_name': 'file.txt',
    'file_content': file_encoded
}

# 将数据传输到 Elasticsearch 中
es.index(index='file_index', doc_type='file', body=data)

在这个示例中，我们先连接到 Elasticsearch，然后读取要传输的文件，并将文件内容进行 base64 编码。接下来，我们定义要传输的数据，包括文件名和编码后的文件内容。最后，我们将数据传输到 Elasticsearch 中，其中 index 参数指定了要传输到哪个索引中，doc_type 参数指定了要传输到哪个文档类型中，body 参数指定了要传输的数据。