Comment puis-je créer un client de protocole WAMP pour le sous-scannage dans Python2?

Question

Je veux créer un client WAMP (Web Application Messaging Protocol) pour m'abonner au ticker de poloniex. Il y a quelques infomation utiles dans le document API de poloniex comme suit:

The best way to get public data updates on markets is via the push API, 
which pushes live ticker, order book, trade, and Trollbox updates over 
WebSockets using the WAMP protocol. In order to use the push API, 
connect to wss://api.poloniex.com and subscribe to the desired feed. 
In order to receive ticker updates, subscribe to "ticker". 

Mais ils ne disent pas comment utiliser python pour vous abonner it.Then je tente de recherche dans Google, je coundn't quoi que ce soit l'aide. Est-ce que quelqu'un peut me montrer comment construire un client WAMP pour sous-traiter le ticker de poloniex? Merci!

----------- -------------- mise à jour j'ai trouvé le code suivant ce qui semble faire ce que je veux:

from autobahn.asyncio.wamp import ApplicationSession 
from autobahn.asyncio.wamp import ApplicationRunner 
from asyncio import coroutine 


class PoloniexComponent(ApplicationSession): 
    def onConnect(self): 
     self.join(self.config.realm) 

    @coroutine 
    def onJoin(self, details): 
     def onTicker(*args): 
      print("Ticker event received:", args) 

     try: 
      yield from self.subscribe(onTicker, 'ticker') 
     except Exception as e: 
      print("Could not subscribe to topic:", e) 


def main(): 
    runner = ApplicationRunner(u"wss://api.poloniex.com:443", "realm1") 
    runner.run(PoloniexComponent) 


if __name__ == "__main__": 
    main() 

Mais il montre l'erreur suivante:

Traceback (most recent call last): 
    File "wamp.py", line 5, in <module> 
    from autobahn.asyncio.wamp import ApplicationSession 
    File "/usr/lib/python2.7/site-packages/autobahn/asyncio/__init__.py", line 36, in <module> 
    from autobahn.asyncio.websocket import \ 
    File "/usr/lib/python2.7/site-packages/autobahn/asyncio/websocket.py", line 32, in <module> 
    txaio.use_asyncio() 
    File "/usr/lib/python2.7/site-packages/txaio/__init__.py", line 122, in use_asyncio 
    from txaio import aio 
    File "/usr/lib/python2.7/site-packages/txaio/aio.py", line 47, in <module> 
    import asyncio 
    File "/usr/lib/python2.7/site-packages/asyncio/__init__.py", line 9, in <module> 
    from . import selectors 
    File "/usr/lib/python2.7/site-packages/asyncio/selectors.py", line 39 
    "{!r}".format(fileobj)) from None 
          ^
SyntaxError: invalid syntax 

J'ai trouvé quelques indices qui semble un certain module ne fonctionne correctement dans python3. Quelle déception!

Answer 1

Enfin, je trouve la réponse suivante, il peut faire ce que je veux:

import websocket 
import thread 
import time 
import json 

def on_message(ws, message): 
    print(message) 

def on_error(ws, error): 
    print(error) 

def on_close(ws): 
    print("### closed ###") 

def on_open(ws): 
    print("ONOPEN") 
    def run(*args): 
     ws.send(json.dumps({'command':'subscribe','channel':1001})) 
     ws.send(json.dumps({'command':'subscribe','channel':1002})) 
     ws.send(json.dumps({'command':'subscribe','channel':1003})) 
     ws.send(json.dumps({'command':'subscribe','channel':'BTC_XMR'})) 
     while True: 
      time.sleep(1) 
     ws.close() 
     print("thread terminating...") 
    thread.start_new_thread(run,()) 


if __name__ == "__main__": 
    websocket.enableTrace(True) 
    ws = websocket.WebSocketApp("wss://api2.poloniex.com/", 
           on_message = on_message, 
           on_error = on_error, 
           on_close = on_close) 
    ws.on_open = on_open 
    ws.run_forever() 

Merci pour l'auteur qui a nommé Ricky Han!