我有以下基本的Django消费渠道:
class EchoConsumer(AsyncJsonWebsocketConsumer):
async def connect(self):
await self.accept()
await self.send_json('Connected!')
同时,我还有一个普通的Python脚本,它连接到websocket并实时接收一些数据:
from binance.client import Client
import json
from binance.websockets import BinanceSocketManager
client = Client('', '')
# get all symbol prices
prices = client.get_all_tickers()
trades = client.get_recent_trades(symbol='BNBBTC')
# start aggregated trade websocket for BNBBTC
def process_message(message):
JSON1 = json.dumps(message)
JSON2 = json.loads(JSON1)
#define variables
Rate = JSON2['p']
Quantity = JSON2['q']
Symbol = JSON2['s']
Order = JSON2['m']
print(Rate, Quantity, Order)
bm = BinanceSocketManager(client)
bm.start_trade_socket('BNBBTC', process_message)
bm.start()
我希望执行以下操作:第二个脚本不只是打印接收到的数据,而是以某种方式将数据发送给Django通道消费者。每当用户打开页面时,该页面都会收到该数据。如果第二个用户同时打开页面,则该第二个用户也应接收数据。有可能这样做吗?我应该使用其他服务吗
因此,如果要将此数据发送到所有当前
open
websocket连接,可以执行以下操作然后,在脚本中需要导入
channels
(并配置了django,因此最好是一个django
命令,请参见:https://docs.djangoproject.com/en/3.0/howto/custom-management-commands/相关问题 更多 >
编程相关推荐