def index_events(client, events):
results = helpers.streaming_bulk(client, events)
for status, r in results:
if not status:
log.debug("index err result %s", r)
微信
公众号
扫码关注公众号