Commit 9ec890e2 authored by Anna Warno's avatar Anna Warno
Browse files

ports changed

parent b058c02a
......@@ -2,13 +2,13 @@ AMQ_HOSTNAME=localhost
AMQ_USER=morphemic
AMQ_PASSWORD=morphemic
AMQ_PORT=61613
AMQ_HOST=147.102.17.76
AMQ_PORT_BROKER=61610
APP_NAME=demo
METHOD=nbeats
METHOD=tft
DATA_PATH=./
INFLUXDB_HOSTNAME=localhost
INFLUXDB_PORT=8086
INFLUXDB_USERNAME=morphemic
INFLUXDB_PASSWORD=password
INFLUXDB_DBNAME=morphemic
AMQ_HOST=localhost
AMQ_PORT_BROKER=61613
......@@ -10,5 +10,5 @@ INFLUXDB_PORT=8086
INFLUXDB_USERNAME=morphemic
INFLUXDB_PASSWORD=password
INFLUXDB_DBNAME=morphemic
AMQ_HOST=147.102.17.76
AMQ_PORT_BROKER=61610
AMQ_HOST=localhost
AMQ_PORT_BROKER=61613
......@@ -94,18 +94,18 @@ def main():
"2", StartForecastingListener(start_conn.conn, START_TOPIC)
)
msg1 = Msg()
msg1.body = '[{"metric": "cpu_usage", "level": 3, "publish_rate": 60000}]'
msg2 = Msg()
msg2.body = """{
"metrics": ["cpu_usage"],
"timestamp": 0,
"epoch_start": 0,
"number_of_forward_predictions": 8,
"prediction_horizon": 120}"""
StartListener(start_conn.conn, START_APP_TOPIC).on_message(msg1)
StartForecastingListener(start_conn.conn, START_APP_TOPIC).on_message(msg2)
# msg1 = Msg()
# msg1.body = '[{"metric": "cpu_usage", "level": 3, "publish_rate": 60000}]'
# msg2 = Msg()
# msg2.body = """{
# "metrics": ["cpu_usage"],
# "timestamp": 0,
# "epoch_start": 0,
# "number_of_forward_predictions": 8,
# "prediction_horizon": 120}"""
# StartListener(start_conn.conn, START_APP_TOPIC).on_message(msg1)
# StartForecastingListener(start_conn.conn, START_APP_TOPIC).on_message(msg2)
while True:
pass
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment