如何解决logstash mutate add_field-索引时如何在python中执行
我在编写索引时在Logstash中使用以下内容:
mutate {add_field => [ "[NEW_FIELD_INT]","%{OLD_FIELD_STRING}" ]}
mutate {convert => {"NEW_FIELD_INT" => "integer"}
如何使用Python使用它?
这是我的转储代码段:
# dump json to index
with open('\path\_file.json') as f:
json_docs = json.loads(f.read())
for json_doc in json_docs:
my_id = json_doc.pop('_id',None)
es.index(index=index_name,doc_type='_doc',id=my_id,body=json.dumps(json_doc))
感谢您的帮助 问候
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。