diff options
| author | Pjotr Prins | 2018-03-20 11:02:25 +0000 |
|---|---|---|
| committer | Pjotr Prins | 2018-03-26 09:29:29 +0000 |
| commit | 7aae77762e47c9269591e138ab25320d3ed3a85f (patch) | |
| tree | 1361829f13fe38e97f58168bff05fae443143285 /wqflask/utility/elasticsearch_tools.py | |
| parent | e2339a0a491f1853b8411d499be1e08bf62a2da8 (diff) | |
| download | genenetwork2-7aae77762e47c9269591e138ab25320d3ed3a85f.tar.gz | |
Refactor startup config for gunicorn and werkzeug
Diffstat (limited to 'wqflask/utility/elasticsearch_tools.py')
| -rw-r--r-- | wqflask/utility/elasticsearch_tools.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/wqflask/utility/elasticsearch_tools.py b/wqflask/utility/elasticsearch_tools.py index 2d3d5add..734379f7 100644 --- a/wqflask/utility/elasticsearch_tools.py +++ b/wqflask/utility/elasticsearch_tools.py @@ -6,6 +6,11 @@ logger = getLogger(__name__) from utility.tools import ELASTICSEARCH_HOST, ELASTICSEARCH_PORT +def test_elasticsearch_connection(): + es = Elasticsearch(['http://'+ELASTICSEARCH_HOST+":"+ELASTICSEARCH_PORT+'/'], verify_certs=True) + if not es.ping(): + logger.warning("Elasticsearch is DOWN") + def get_elasticsearch_connection(): logger.info("get_elasticsearch_connection") es = None |