首页 > 开发 > Python > 正文

在python函数执行过程中,如何判断并处理其中一条语句的返回值?

2017-09-06 19:16:49  来源:网友分享

本人在使用elasticsearch自带的python api编写一些日志简单处理之后写入es的python脚本。
比如
def es_write(index_name,type,id,body):

from elasticsearch import Elasticsearch
es = 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系统命令,并处理其返回值。

解决方案

这个模块应该也是有返回一个json处理结果的,你可以试下下面语句:

result = es.create(index=index_name,doc_type=type,id=id,body=body)
print result