Merge pull request #29 from TogetherCrew/update-module-name

Update module name and added env examples!

.env.example

@@ -1 +1,23 @@
-GITHUB_TOKEN=daolytics_access_token
+AUTOMATION_DB_COLLECTION=
+AUTOMATION_DB_NAME=
+MONGODB_HOST=
+MONGODB_PASS=
+MONGODB_PORT=
+MONGODB_USER=
+NEO4J_DB=
+NEO4J_HOST=
+NEO4J_PASSWORD=
+NEO4J_PORT=
+NEO4J_PROTOCOL=
+NEO4J_USER=
+RABBIT_HOST=
+RABBIT_PASSWORD=
+RABBIT_PORT=
+RABBIT_USER=
+REDIS_HOST=
+REDIS_PASSWORD=
+REDIS_PORT=
+SAGA_DB_COLLECTION=
+SAGA_DB_NAME=
+SENTRY_DSN=
+SENTRY_ENV=

Dockerfile

@@ -9,4 +9,4 @@ RUN chmod +x docker-entrypoint.sh
 CMD ["./docker-entrypoint.sh"]
 
 FROM base AS prod
-CMD ["python3", "start_rabbit_mq.py"]
+CMD ["python3", "server.py"]

docker-compose.example.yml

@@ -6,7 +6,7 @@ services:
       context: .
       target: prod
       dockerfile: Dockerfile
-    command: python3 start_rabbit_mq.py
+    command: python3 server.py
   worker:
     build:
       context: .

worker.py

@@ -1,11 +1,8 @@
 import logging
-import os
 
 import redis
-from dotenv import load_dotenv
 from rq import Worker
-
-load_dotenv()
+from utils.daolytics_uitls import get_redis_credentials
 
 
 def worker_exception_handler(job, exc_type, exc_value, traceback):
@@ -17,18 +14,18 @@ def worker_exception_handler(job, exc_type, exc_value, traceback):
 
 
 if __name__ == "__main__":
-    host = os.getenv("REDIS_HOST", "")
-    port = int(os.getenv("REDIS_PORT", 6379))
-    password = os.getenv("REDIS_PASSWORD")
+    redis_creds = get_redis_credentials()
 
     logging.basicConfig()
     logging.getLogger().setLevel(logging.INFO)
 
-    redis_connection = redis.Redis(host=host, port=port, password=password)
+    host = redis_creds["host"]
+    port = redis_creds["port"]
+    password = redis_creds["pass"]
+
+    r = redis.Redis(host=host, port=port, password=password)
     worker = Worker(
-        queues=["default"],
-        connection=redis_connection,
-        exception_handlers=worker_exception_handler,
+        queues=["default"], connection=r, exception_handlers=worker_exception_handler
     )
     try:
         worker.work(with_scheduler=True, max_jobs=1)