SNO-191-pyramid-env-vars (#318)

Author: paul-sud

.gitignore

@@ -36,3 +36,4 @@
 
 .python-version
 .vscode
+venv

src/snovault/app.py

@@ -1,5 +1,6 @@
 import base64
 import codecs
+import copy
 import json
 import os
 
@@ -52,7 +53,9 @@ def changelogs(config):
 
 
 def configure_engine(settings):
-    engine_url = settings['sqlalchemy.url']
+    settings = copy.deepcopy(settings)
+    engine_url = os.environ.get("SQLALCHEMY_URL") or settings['sqlalchemy.url']
+    settings["sqlalchemy.url"] = engine_url
     engine_opts = {}
     if engine_url.startswith('postgresql'):
         if settings.get('indexer_worker'):

src/snovault/elasticsearch/__init__.py

@@ -1,4 +1,5 @@
 import logging
+import os
 
 from snovault.json_renderer import json_renderer
 from snovault.util import get_root_request
@@ -28,7 +29,9 @@ def includeme(config):
 
     config.add_request_method(datastore, 'datastore', reify=True)
 
-    addresses = aslist(settings['elasticsearch.server'])
+    addresses = aslist(
+        os.environ.get("ELASTICSEARCH_URL") or settings['elasticsearch.server']
+    )
     config.registry[ELASTIC_SEARCH] = Elasticsearch(
         addresses,
         serializer=PyramidJSONSerializer(json_renderer),

src/snovault/elasticsearch/indexer.py

@@ -160,7 +160,10 @@ def get_related_uuids(request, es, updated, renamed):
 
 
 def _determine_indexing_protocol(request, uuid_count):
-    remote_indexing = asbool(request.registry.settings.get('remote_indexing', False))
+    remote_indexing = asbool(
+        os.environ.get("REMOTE_INDEXING")
+        or request.registry.settings.get('remote_indexing', False)
+    )
     if not remote_indexing:
         return False
     try:
@@ -351,7 +354,10 @@ def index(request):
     # Check remote indexing and set head/indexing nodes
     this_node = indexer_state.get_obj(INDEXING_NODE_INDEX)
     other_node = indexer_state.get_obj(HEAD_NODE_INDEX)
-    remote_indexing = asbool(request.registry.settings.get('remote_indexing', False))
+    remote_indexing = asbool(
+        os.environ.get("REMOTE_INDEXING")
+        or request.registry.settings.get('remote_indexing', False)
+    )
     did_timeout = False
     if remote_indexing:
         this_node, other_node, continue_on, did_timeout = _get_nodes(request, indexer_state)