facebook / facebook/prophet

Conflict with RabbitMQ Connection

Open
#1,904 0 comments 0 reactions 0 assignees View on GitHub
py
Dominant language
Python
Stars
20.4k
Forks
4.6k
Avg merge
19h 52m
Merged PRs (30d)
1

Description

I'm trying to use Prophet forecast some data, and send the data through RabbitMQ. But I got the error when I send the message after run Prophet. The error won't appear if I send a message without running Prophet. So I think Prophet has some conflicting with RabbitMQ connection.
Here is my code:

```
import pika
import json
import pandas as pd
from prophet import Prophet
import matplotlib.pyplot as plt

def producter(message):
connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
channel = connection.channel()
channel.queue_declare(queue='new_queue1')
channel.basic_publish(exchange='', routing_key='new_queue1', body=message)
connection.close()

def forcast():
df = pd.read_csv('data/example_wp_log_peyton_manning.csv')
m = Prophet()
m.fit(df)
future = m.make_future_dataframe(periods=365)
forecast = m.predict(future)
m.plot(forecast)
plt.savefig('plot.png')

forecast_data = {'processTime': 202105110000, 'granularity': 'DAY', 'granSize': 1, 'data': 'Some Forecast data'}
message = json.dumps(forecast_data)
producter(message)

def send_message():
forecast_data = {'processTime': 202105110000, 'granularity': 'DAY', 'granSize': 1, 'data': 'Some Forecast data'}
message = json.dumps(forecast_data)
producter(message)

if __name__ == '__main__':
send_message()
forcast()
```

and the error is:

```
INFO:prophet:Disabling daily seasonality. Run prophet with daily_seasonality=True to override this.
Initial log joint probability = -19.4685
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
99 7975.67 0.000771564 153.766 1 1 128
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
199 7993.12 0.00902596 706.023 1 1 244
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
299 7997.04 0.000598881 254.701 0.6649 0.6649 364
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
326 7998.31 6.74321e-005 177.981 5.29e-007 0.001 433 LS failed, Hessian reset
399 7999.84 0.0036172 469.05 1 1 532
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
438 8000.61 3.88948e-005 132.06 2.582e-007 0.001 610 LS failed, Hessian reset
499 8001.35 0.00169333 116.222 1 1 693
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
599 8003.33 0.000166291 101.616 1 1 815
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
699 8003.91 0.00147259 69.7156 1 1 943
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
746 8004.19 3.80422e-005 111.925 1.891e-007 0.001 1061 LS failed, Hessian reset
799 8004.68 0.00037343 76.5473 1 1 1128
Iter log prob ||dx|| ||grad|| alpha alpha0 # evals Notes
832 8004.74 4.45685e-005 72.8597 6.878e-007 0.001 1210 LS failed, Hessian reset
886 8004.75 3.79006e-007 55.396 0.8123 0.8123 1287
Optimization terminated normally:
Convergence detected: relative gradient magnitude is below tolerance
INFO:pika.adapters.utils.connection_workflow:Pika version 1.2.0 connecting to ('::1', 5672, 0, 0)
INFO:pika.adapters.utils.io_services_utils:Socket connected:
INFO:pika.adapters.utils.connection_workflow:Streaming transport linked up: (, _StreamingProtocolShim: params=>).
INFO:pika.adapters.utils.connection_workflow:AMQPConnector - reporting success: params=>
INFO:pika.adapters.utils.connection_workflow:AMQPConnectionWorkflow - reporting success: params=>
INFO:pika.adapters.blocking_connection:Connection workflow succeeded: params=>
INFO:pika.adapters.blocking_connection:Created channel=1
INFO:pika.adapters.blocking_connection:Closing connection (200): Normal shutdown
INFO:pika.channel:Closing channel (200): 'Normal shutdown' on params=>>
INFO:pika.channel:Received on params=>>
INFO:pika.connection:Closing connection (200): 'Normal shutdown'
INFO:pika.adapters.utils.io_services_utils:Aborting transport connection: state=1; INFO:pika.adapters.utils.io_services_utils:_AsyncTransportBase._initate_abort(): Initiating abrupt asynchronous transport shutdown: state=1; error=None;
INFO:pika.adapters.utils.io_services_utils:Deactivating transport: state=1;
INFO:pika.connection:AMQP stack terminated, failed to connect, or aborted: opened=True, error-arg=None; pending-error=ConnectionClosedByClient: (200) 'Normal shutdown'
INFO:pika.connection:Stack terminated due to ConnectionClosedByClient: (200) 'Normal shutdown'
INFO:pika.adapters.utils.io_services_utils:Closing transport socket and unlinking: state=3;
INFO:pika.adapters.blocking_connection:User-initiated close: result=BlockingConnection__OnClosedArgs(connection=>, error=ConnectionClosedByClient: (200) 'Normal shutdown')
```

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.