Hi all,

This is not exactly a scikit-learn question but I am trying to send the
output of a model into an exchange of Rabbit MQ.

I will convert the dataframe into json before sending it to the exchange.

This sample code is not sending messages. Any ideas?


#!/usr/bin/env python
import pika
credentials = pika.PlainCredentials('admin', '')
connection = pika.BlockingConnection(pika.ConnectionParameters(
               '<....>,'/',credentials))
channel = connection.channel()

## have masked the password and ip details above

channel.basic_publish(exchange='CRM:TripPropensityUpdated',
                      routing_key='',
                      body='Hello World',
                      properties=pika.BasicProperties(
                         delivery_mode = 1, # make message persistent
                      ))
print (channel.basic_ack(delivery_tag = 1,multiple=1))


*The final output is None *which means the message is not being sent.

Regards,
Sanant
------------------------------------------------------------------------------
Site24x7 APM Insight: Get Deep Visibility into Application Performance
APM + Mobile APM + RUM: Monitor 3 App instances at just $35/Month
Monitor end-to-end web transactions and take corrective actions now
Troubleshoot faster and improve end-user experience. Signup Now!
http://pubads.g.doubleclick.net/gampad/clk?id=267308311&iu=/4140
_______________________________________________
Scikit-learn-general mailing list
Scikit-learn-general@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/scikit-learn-general

Reply via email to