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

本人在使用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系统命令，并处理其返回值。