orchestration server is no real "server" anymore, does not expose any REST API, only starts all the msg queues and waits for incoming requests.
This commit is contained in:
parent
9aa13bed7b
commit
3701121aed
@ -1,28 +1,4 @@
|
|||||||
import threading
|
|
||||||
|
|
||||||
import requests
|
|
||||||
from flask import Flask
|
|
||||||
from orchestrator import Orchestrator
|
from orchestrator import Orchestrator
|
||||||
|
|
||||||
app = Flask(__name__)
|
|
||||||
|
|
||||||
|
|
||||||
@app.route('/')
|
|
||||||
def hello_world():
|
|
||||||
return 'Hello World'
|
|
||||||
|
|
||||||
|
|
||||||
@app.route('/api1')
|
|
||||||
def api1():
|
|
||||||
return 'api1'
|
|
||||||
|
|
||||||
|
|
||||||
@app.route('/api2')
|
|
||||||
def api2():
|
|
||||||
return 'api2'
|
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
orc = Orchestrator()
|
Orchestrator().setup_msg_queues()
|
||||||
threading.Thread(target=orc.setup_msg_queues).start()
|
|
||||||
threading.Thread(target=app.run, args=('0.0.0.0', 5003)).start()
|
|
||||||
|
|||||||
@ -53,10 +53,6 @@ services:
|
|||||||
depends_on:
|
depends_on:
|
||||||
- rabbitmq
|
- rabbitmq
|
||||||
- entityident
|
- entityident
|
||||||
expose:
|
|
||||||
- 5003
|
|
||||||
ports:
|
|
||||||
- 5003:5003
|
|
||||||
ifeed:
|
ifeed:
|
||||||
build:
|
build:
|
||||||
context: ../components/i_feed
|
context: ../components/i_feed
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user