在 python 脚本中,
我正在尝试让elasticsearch.helpers.bulk存储多条记录。
我将从另一个软件中得到一个 json 格式的字符串,我想将它附加到源部分
我的代码的一部分:
def saveES(output,name):
es = Elasticsearch([{'host':'localhost','port':9200}])
output = output.split('\n')
i=0
datas=[]
while i<len(output):
data = {
"_index":"name",
"_type":"typed",
"_id":saveES.counter,
"_source":[[PROBLEM]]
}
i+=1
saveES.counter+=1
datas.append(data)
helpers.bulk(es, datas)
我想在 [[PROBLEM]] 中附加一个 json 格式的字符串
我怎样才能把它贴进去?我已经努力了,但它没有正确输出..
如果我使用:
"_source":{
"image_name":'"'+name+'",'+output[i]
}
打印数据结果为:
{'_type': 'typed', '_id': 0, '_source': {'image_name': '"nginx","features": "os,disk,package", "emit_shortname": "f0b03efe94ec", "timestamp": "2017-08-18T17:25:46+0900", "docker_image_tag": "latest"'}, '_index': 'name'}
这个结果表明组合成一个字符串。
但我希望:
{'_type': 'typed', '_id': 0, '_source': {'image_name': 'nginx','features': 'os,disk,package', 'emit_shortname': 'f0b03efe94ec', 'timestamp': '2017-08-18T17:25:46+0900', 'docker_image_tag': 'latest'}, '_index': 'name'}