diff options
| author | zsloan | 2018-04-04 12:15:45 -0500 |
|---|---|---|
| committer | GitHub | 2018-04-04 12:15:45 -0500 |
| commit | b152aca03be73655d2fb5eda17d533504ed900e2 (patch) | |
| tree | 8e6b5d3810081d44b59f91e15fbf1702c444f7af /wqflask/utility | |
| parent | 57e6d490cf8c7acb326552456a597f1e1cdecc2c (diff) | |
| parent | 273c72ef02f839b88b3d2ad504e9d84eab0f9ec5 (diff) | |
| download | genenetwork2-b152aca03be73655d2fb5eda17d533504ed900e2.tar.gz | |
Merge pull request #303 from pjotrp/testing
Minor edits and document on ES
Diffstat (limited to 'wqflask/utility')
| -rw-r--r-- | wqflask/utility/elasticsearch_tools.py | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/wqflask/utility/elasticsearch_tools.py b/wqflask/utility/elasticsearch_tools.py index 734379f7..1dba357d 100644 --- a/wqflask/utility/elasticsearch_tools.py +++ b/wqflask/utility/elasticsearch_tools.py @@ -12,6 +12,7 @@ def test_elasticsearch_connection(): logger.warning("Elasticsearch is DOWN") def get_elasticsearch_connection(): + """Return a connection to ES. Returns None on failure""" logger.info("get_elasticsearch_connection") es = None try: @@ -20,14 +21,14 @@ def get_elasticsearch_connection(): logger.info("ES HOST",ELASTICSEARCH_HOST) es = Elasticsearch([{ - "host": ELASTICSEARCH_HOST - , "port": ELASTICSEARCH_PORT + "host": ELASTICSEARCH_HOST, "port": ELASTICSEARCH_PORT }]) if (ELASTICSEARCH_HOST and ELASTICSEARCH_PORT) else None es_logger = logging.getLogger("elasticsearch") es_logger.setLevel(logging.INFO) es_logger.addHandler(logging.NullHandler()) except: + logger.error("Failed to get elasticsearch connection") es = None return es @@ -42,9 +43,7 @@ def get_item_by_unique_column(es, column_name, column_value, index, doc_type): item_details = None try: response = es.search( - index = index - , doc_type = doc_type - , body = { + index = index, doc_type = doc_type, body = { "query": { "match": { column_name: column_value } } }) if len(response["hits"]["hits"]) > 0: |