将数据从 celery 发送到 tornado websocket

Question

我有一些使用 Celery 执行的周期性任务（解析页面）。 我还用龙卷风建立了一个 websocket。

我想将周期性任务中的数据传递给 tornado，然后将此数据写入 websocket 并在我的 html 页面上使用此数据。

我该怎么做？

我尝试从我的带有 celery 任务的模块中导入带有 tornado websocket 的模块，但是当然，这没有用。

如果我从客户端收到消息，我只知道如何返回一些数据。我是这样处理的：

import tornado.httpserver
import tornado.websocket
import tornado.ioloop
import tornado.web
import socket
'''
This is a simple Websocket Echo server that uses the Tornado websocket handler.
Please run `pip install tornado` with python of version 2.7.9 or greater to install tornado.
This program will echo back the reverse of whatever it recieves.
Messages are output to the terminal for debuggin purposes. 
''' 
class handler():
    wss = []



class WSHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        print ('new connection')
        if self not in handler.wss:
            handler.wss.append(self)

    def on_message(self, message):
        print ('message received: ' + message)
        wssend('Ihaaaa')

    def on_close(self):
        print ('connection closed')
        if self in handler.wss:
            handler.wss.remove(self)

    def check_origin(self, origin):
        return True


def wssend(message):
    print(handler.wss)
    for ws in handler.wss:
        if not ws.ws_connection.stream.socket:
            print ("Web socket does not exist anymore!!!")
            handler.wss.remove(ws)
        else:
            print('I am trying!')
            ws.write_message(message)
            print('tried')

application = tornado.web.Application([
    (r'/ws', WSHandler),
])


if __name__ == "__main__":
    http_server = tornado.httpserver.HTTPServer(application)
    http_server.listen(8888)
    myIP = socket.gethostbyname(socket.gethostname())
    print ('*** Websocket Server Started at %s***' % myIP)
    main_loop = tornado.ioloop.IOLoop.instance()
    main_loop.start()

Answer 1

选项是在龙卷风中创建一个句柄，然后将芹菜任务的结果发布到这个句柄。 之后，就有机会将此数据传递给 websocket。