python的signalr客户端

signalrc的Python项目详细描述


python signaler客户端

注意:库当前与asp.net core signaler(.net core 2.1)不兼容,因为那里的signaler协议发生了更改

使用PIP安装

pip install signalrc

用法

import json
from base64 import b64decode
from zlib import MAX_WBITS, decompress

from signalrc.signalrc import SignalRClient


def decode_message(message):
    deflated_msg = decompress(b64decode(message), -MAX_WBITS)
    return json.loads(deflated_msg.decode())


def on_debug(**msg):
    print(msg)
    if 'R' in msg and type(msg['R']) is not bool:
        decoded_msg = decode_message(msg['R'])
        print(decoded_msg)


def on_message(msg):
    decoded_msg = decode_message(msg)
    print(decoded_msg)


def on_error(msg):
    print(msg)


signalr_client = SignalRClient("https://socket.bittrex.com/signalr", hub='c2')

signalr_client.start()

signalr_client.received.add_hooks(on_debug)
signalr_client.error.add_hooks(on_error)

signalr_client.subscribe_to_event('uE', on_message)

signalr_client.invoke('queryExchangeState', 'USD-BTC')
signalr_client.invoke('SubscribeToExchangeDeltas', 'USD-BTC')

signalr_client.run_while_open()

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何在Android Wifi中筛选相同的SSID?   Java中重写接口中异常处理的泛型   java“无效转义序列(有效的是\b\t\n\f\r\”\“\”\)”语法错误   使用JNDI的java NameReadyBoundException   java如何在这个程序上执行算法   java为什么我的应用程序在调试时崩溃而应用程序停止?   Java:while循环未检测到中断条件,但如果块检测到   java如何快速使用jfreechart创建的折线图   java将输入放入JSTL会话变量,以便稍后在屏幕上显示   java在spring boot中加载外部JAR   java Apache NiFi无法使用ojdbc6连接到Oracle 12c。jar或ojdbc8。罐子   java解释StringToWordVector()Weka的输出   java charAt()找不到符号   使用mpjexpress的java阅读控制台输入