Skip to content
Snippets Groups Projects
Commit 35e6e126 authored by Martin Weise's avatar Martin Weise
Browse files

Merge branch '245-fix-broker-service' into 'dev'

Fixed the problem

See merge request !108
parents e6da52d0 9deee8ff
No related branches found
No related tags found
4 merge requests!129New module for citation as they occur multiple,!121Modified logging, modified logging level, modified flasgger endpoint,!113Resolve "Bugs related with Query Service",!108Fixed the problem
...@@ -15,7 +15,7 @@ RUN apk --no-cache add python3 py3-pip ...@@ -15,7 +15,7 @@ RUN apk --no-cache add python3 py3-pip
COPY ./requirements.txt ./requirements.txt COPY ./requirements.txt ./requirements.txt
RUN pip3 install -r ./requirements.txt RUN pip3 install -r ./requirements.txt
COPY init.py ./init.py COPY ./init.py ./init.py
EXPOSE 15692 EXPOSE 15692
......
#!/bin/bash #!/bin/bash
rabbitmq-server &
# enable prometheus plugin # enable prometheus plugin
sleep 10 && rabbitmq-plugins enable rabbitmq_prometheus (sleep 10; rabbitmq-plugins enable rabbitmq_prometheus) &
# register with discovery service # register with discovery service
python3 ./init.py python3 ./init.py
(while sleep 60; do python3 ./init.py; done) &
rabbitmq-server
\ No newline at end of file
from py_eureka_client import eureka_client from py_eureka_client import eureka_client
import py_eureka_client.logger as logger import py_eureka_client.logger as logger
from time import sleep import datetime
logger.set_level("ERROR") logger.set_level("ERROR")
print("Registering at discovery service ...")
def register(first=False): def register():
eureka_client.init(eureka_server="http://discovery-service:9090/eureka/", app_name="broker-service", eureka_client.init(eureka_server="http://discovery-service:9090/eureka/",
app_name="broker-service",
instance_ip="broker-service", instance_ip="broker-service",
instance_host="broker-service", instance_host="broker-service",
instance_port=15672) instance_port=15672)
if first: log("Service registered")
print("Service was registered at Eureka server")
def log(message):
date = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
print(f"{date} LOG: {message}")
if __name__ == "__main__": if __name__ == "__main__":
register(first=True) log("Registering at discovery service ...")
while True:
register() register()
sleep(60)
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment