Всем привет. Ищу совета у специалистов, очень нужна помощь, тех поддержка отмалчивается!
Пытаюсь поднять получение полного ордерлога с poloniex на питоне.
Получилось поднять подписку по протоколу WAMP но только на подписку 'tikcer' как это указано в документации: https://poloniex.com/support/api/
Однако, при попытке подписаться непосредственно на какую либо конкретную пару(в коде это BTC_XMR) получаю только сообщения heartbeat по всей видимости. В интернете подобных ошибок не нашел, техподдержка молчит, буду признателен за любую информацию.
Вот исходный код:
class MyComponent(ApplicationSession):
def __init__(self, config=None):
ApplicationSession.__init__(self, config)
print("component created")
def onConnect(self):
print("transport connected")
self.join(self.config.realm)
def onChallenge(self, challenge):
print("authentication challenge received")
async def onJoin(self, details):
print("session joined")
def on_event(*args, **kwargs):
print("args:", args, " kwargs:", kwargs)
try:
await self.subscribe(on_event, u'BTC_XMR')
print("subscribed to topic")
except Exception as e:
print("could not subscribe to topic: {0}".format(e))
asyncio.get_event_loop().call_later(30, self.leave)
def onLeave(self, details):
print("session left")
self.disconnect()
def onDisconnect(self):
print("transport disconnected")
asyncio.get_event_loop().stop()
if __name__ == '__main__':
runner = ApplicationRunner(url=u"wss://api.poloniex.com", realm=u"realm1")
runner.run(MyComponent)
А вот лог:
component created transport connected session joined subscribed to topic args: () kwargs: {'seq': 209762586} args: () kwargs: {'seq': 209762594} args: () kwargs: {'seq': 209762626} args: () kwargs: {'seq': 209762634} session left
transport disconnected
Как видно из лога мне приходят только пустые сообщения с seq по всей видимости это и есть тот самый heartbeat. Как начать получать сообщения которые описаны в документации не как не могу понять. Кто поднимал подписку через WAMP для poloniex отзовитесь пожалуйста!