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中的字符串字符下打印星号(*)   java在比较数据后得到错误的结果   java如何在使用JSP创建的网站中创建父子关系和处理?   java配置单元UDF:无法执行求值方法   java GAE项目Intellij远程调试在关闭时不释放端口   java按钮上的放大和缩小功能点击JfreeChart折线图?   java Selenium Chrome Web驱动程序SessionNotCreatedException   java由ADFactoryBuilder生成的线程工厂是线程安全的吗?   java将字符串[]传递给另一个类Android(使用intent)   我为什么要嘲笑java?   JavaLiferay门户不将对象从流程阶段发送到jsp   java我想在单击每个树节点时将要添加的信息放入jpanel jscrollpane中   在Java中模拟数组引用(即对引用的引用)的按引用传递   Jackson将JSON属性反序列化为不同的Java对象   java使用JSP/servlet在网页上显示Excel工作表?   仿射变换Java:使用仿射变换时游戏速度减慢   Servlet JBoss AS 7的java EJB注入   在Oracle数据库中使用Java的plsql   java管理Maven项目中的库依赖项   JavaEclipseLink(JPA)异常:复合主键@JoinColumn