如何在我的主要Django应用程序进程中访问Celery任务的结果？或者，如何从单独的进程发布到现有套接字连接？我有一个用户可以收到分数的应用程序。当记录分数时，会进行计算(目标进展等)，并根据这些计算向感兴趣的用户发送通知。计算可能需要30秒以上，因此为了避免UI缓慢，这些操作通过Celery任务在后台进程中执行，由我的Score模型的post_save信号调用。理想情况下，我的Nofication模型上的post_save信号会向订阅的客户端发布消息(我正在使用django-socketio，gevent-socketio的包装器)。这看起来很简单......创建乐谱在后台进程中对
如何在我的主要Django应用程序进程中访问Celery任务的结果？或者，如何从单独的进程发布到现有套接字连接？我有一个用户可以收到分数的应用程序。当记录分数时，会进行计算(目标进展等)，并根据这些计算向感兴趣的用户发送通知。计算可能需要30秒以上，因此为了避免UI缓慢，这些操作通过Celery任务在后台进程中执行，由我的Score模型的post_save信号调用。理想情况下，我的Nofication模型上的post_save信号会向订阅的客户端发布消息(我正在使用django-socketio，gevent-socketio的包装器)。这看起来很简单......创建乐谱在后台进程中对
我正在构建一个应用程序，让学生能够查看由管理员创建的日程安排。现在每个学生都有一个group_id。我想实时更新时间表，所以我应用了本教程http://www.kodeinfo.com/post/realtime-app-using-laravel-nodejs-angularjs-redis.这是我到目前为止所做的。事件处理器:namespaceechooly\Handlers;useRedis;useResponse;classStudentScheduleUpdatedEventHandler{CONSTEVENT='schedule.update';CONSTCHANNEL='
我正在构建一个应用程序，让学生能够查看由管理员创建的日程安排。现在每个学生都有一个group_id。我想实时更新时间表，所以我应用了本教程http://www.kodeinfo.com/post/realtime-app-using-laravel-nodejs-angularjs-redis.这是我到目前为止所做的。事件处理器:namespaceechooly\Handlers;useRedis;useResponse;classStudentScheduleUpdatedEventHandler{CONSTEVENT='schedule.update';CONSTCHANNEL='
基于此答案的问题:https://stackoverflow.com/a/18650183/4478897我试图找到这个解决方案，但似乎没有任何效果符合我的需要。集群expressjs和socket.io我们可以使用redis共享session并在io世界中发送io消息(io.sockets.on('connection',...)。问题是如果我们要发送消息(或使用简单的socket.join/leave)在expressjs世界中(route.get/post)。如果我们不使用集群，我们可以将客户端socket对象附加到expressrequest对象(或者简单地exportio对象
基于此答案的问题:https://stackoverflow.com/a/18650183/4478897我试图找到这个解决方案，但似乎没有任何效果符合我的需要。集群expressjs和socket.io我们可以使用redis共享session并在io世界中发送io消息(io.sockets.on('connection',...)。问题是如果我们要发送消息(或使用简单的socket.join/leave)在expressjs世界中(route.get/post)。如果我们不使用集群，我们可以将客户端socket对象附加到expressrequest对象(或者简单地exportio对象
我正在学习使用redis和socket.io，考虑到它们具有的优势。特别是，我也试图将它们用于用户身份验证。如果有人用简单的代码解释给我一个初步的插入，我将不胜感激。我使用的框架是express。我读到express和socket.io不能直接相互交谈。我找到了关于这个的相关链接Socket.IOAuthentication但我不太明白数据库事务是如何从那里给出的答案中发生的。 最佳答案 参见http://www.danielbaulig.de/socket-ioexpress/ 关于n
我正在学习使用redis和socket.io，考虑到它们具有的优势。特别是，我也试图将它们用于用户身份验证。如果有人用简单的代码解释给我一个初步的插入，我将不胜感激。我使用的框架是express。我读到express和socket.io不能直接相互交谈。我找到了关于这个的相关链接Socket.IOAuthentication但我不太明白数据库事务是如何从那里给出的答案中发生的。 最佳答案 参见http://www.danielbaulig.de/socket-ioexpress/ 关于n
使用socket.ioredisstore适配器/存储(？)，是否可以“查看”所有客户端并“选择”甚至是未直接连接到您的socket.io服务器的客户端？还是仅限于socket.io的“房间”功能？举一个实际的例子，同一个聊天室中的两个用户连接到两个不同的socket.ioNode，rediststore适配器/存储是否可以在不对代码进行大量更改的情况下从一个用户到另一个用户窃窃私语，如果您已经有了一个有效的单一进程/服务器实现？我问的原因是我目前还没有处于项目的开发阶段而过度关注缩放(我也没有时间深入研究node.js缩放背后的概念，它看起来与我已经习惯了(现在是第一个完整的node
使用socket.ioredisstore适配器/存储(？)，是否可以“查看”所有客户端并“选择”甚至是未直接连接到您的socket.io服务器的客户端？还是仅限于socket.io的“房间”功能？举一个实际的例子，同一个聊天室中的两个用户连接到两个不同的socket.ioNode，rediststore适配器/存储是否可以在不对代码进行大量更改的情况下从一个用户到另一个用户窃窃私语，如果您已经有了一个有效的单一进程/服务器实现？我问的原因是我目前还没有处于项目的开发阶段而过度关注缩放(我也没有时间深入研究node.js缩放背后的概念，它看起来与我已经习惯了(现在是第一个完整的node
