-import urllib3
import json
+
+import urllib3
+
http = urllib3.PoolManager()
json_dump = json.dumps(json_ojb)
if output_destination == 'stdout':
print json_dump
+ return 200, None
else:
headers = urllib3.make_headers(basic_auth=creds)
- http.request('POST', output_destination, headers=headers, body=json_dump)
+ result = http.request('POST', output_destination, headers=headers, body=json_dump)
+ return result.status, result.data
def _get_nr_of_hits(elastic_json):
for hit in elastic_json['hits']['hits']:
elastic_data.append(hit[field])
return elastic_data
-