elasticsearch - 在python函数执行过程中,如何判断并处理其中一条语句的返回值?
问题描述
本人在使用elasticsearch自带的python api编写一些日志简单处理之后写入es的python脚本。比如def es_write(index_name,type,id,body):
from elasticsearch import Elasticsearches = Elasticsearch()es.create(index=index_name,doc_type=type,id=id,body=body)
es.create就是最基础向es中创建内容的语句。之后就如同在elasticsearch-head或者在linux中使用curl命令对es进行操作后,会返回一个json块。会告诉你,哪些hits被修改,或者有没有修改成功。如果操作失败,就会在json块中显示timed_out:True,failed:xxx之类的字样这样就不能用python自带的抛出异常那一套来侦测。我想问下如何在函数中处理这样的内容。如果命令返回的json块中有失败或者超时的字样,就 使用logging打印错误日志之类的。
个人基础确实不太好,我记得python之前有个subprocess相关的模块,可以打开新的线程,但是百度了一下,基本都是执行linux系统命令,并处理其返回值。
问题解答
回答1:这个模块应该也是有返回一个json处理结果的,你可以试下下面语句:
result = es.create(index=index_name,doc_type=type,id=id,body=body)print result