From: SerenaFeng Date: Wed, 22 Jun 2016 12:46:56 +0000 (+0800) Subject: add log info when publish json to elasticsearch failed X-Git-Tag: colorado.1.0~329 X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=commitdiff_plain;h=fa07c352a88830c985991b361068778239cb9cab;p=releng.git add log info when publish json to elasticsearch failed add logger.info when publish failed JIRA: FUNCTEST-325 Change-Id: I353001c4305af31dd725e0977ced53d52ba79470 Signed-off-by: SerenaFeng --- diff --git a/utils/test/scripts/mongo_to_elasticsearch.py b/utils/test/scripts/mongo_to_elasticsearch.py index a569ac61c..2ffbc1713 100644 --- a/utils/test/scripts/mongo_to_elasticsearch.py +++ b/utils/test/scripts/mongo_to_elasticsearch.py @@ -395,7 +395,12 @@ def publish_mongo_data(output_destination): for mongo_json_line in fobj: test_result = json.loads(mongo_json_line) if modify_mongo_entry(test_result): - shared_utils.publish_json(test_result, es_creds, output_destination) + status, data = shared_utils.publish_json(test_result, es_creds, output_destination) + if status > 300: + project = test_result['project_name'] + case_name = test_result['case_name'] + logger.info('project {} case {} publish failed, due to [{}]' + .format(project, case_name, json.loads(data)['error']['reason'])) finally: if os.path.exists(tmp_filename): os.remove(tmp_filename) diff --git a/utils/test/scripts/shared_utils.py b/utils/test/scripts/shared_utils.py index 91ce38e45..8bbbdbe07 100644 --- a/utils/test/scripts/shared_utils.py +++ b/utils/test/scripts/shared_utils.py @@ -12,9 +12,11 @@ def publish_json(json_ojb, creds, output_destination): 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):