Kucoin Websocket APIへの接続について。

Question

Kucoin Websocket APIへの接続について、アドバイスを頂きたいです。
https://github.com/Kucoin/kucoin-python-sdkに載っている、Websocketsのサンプルコードを動かしたいのですが、Websocket APIからデータを取得しようとすると、データが表示されず、スリーピングループに陥ってしまいます。
どうしたらデータを出力できるでしょうか。
WebsocketやAPIについて勉強し始めたばかりで皆目検討が付かず困っています。よろしくお願いします。

以下はそのコードです。

import asyncio
from kucoin.client import WsToken
from kucoin.ws_client import KucoinWsClient


async def main():
    async def deal_msg(msg):
        if msg['topic'] == '/market/level3:BTC-USDT':
            print(msg["data"])
        elif msg['topic'] == '/market/level3:KCS-USDT':
            print(f'Get KCS level3:{msg["data"]}')

    # is public
    # client = WsToken()
    #is private
    client = WsToken(key='', secret='', passphrase='', is_sandbox=True, url='')
    ws_client = await KucoinWsClient.create(None, client, deal_msg, private=True)
    await ws_client.subscribe('/market/level3:BTC-USDT,KCS-USDT')
    while True:
        await asyncio.sleep(60, loop=loop)


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

Comments

[jamjam3]

このプログラムの目的ってなんですか？
なにをしようとしてなにができていないのですか？

[udon333]

プログラムの最終目的は、Kucoinで自分が注文した取引が完了した時にメッセージを受け取り出力することです。(そのためには、websocketを使ってプライベートチャンネルメッセージを購読したいと考えています。)
上記に載せたコードでは、そもそもwebsocketを使いチャンネルメッセージを出力できるか確認しようとしているのですが、await asyncio.sleep(60, loop=loop)と出力されるだけで、メッセージを受け取ることができていません。
説明が分かりにくく、申し訳ありません。

[jamjam3]

`client = WsToken(key='', secret='', passphrase='', is_sandbox=True, url='')`
keyにKucoinのAPI Keyとかを入れないといけないと思うのですが（他の引数も同様）これは入力されてますか？

[udon333]

入力しています。ここでは念の為省略しました。

Answer 1

まずは基本的な動作を確認していくのが良いのではないでしょうか。
WsTokenはパラメータ無しでも動作しますよね。その場合には動作するのか、sandboxのみTrueにした場合はどうなのか、など試してみてはいかがでしょうか。

それらが全てうまく動くようであれば、取得したアカウントとパラメータがあっていないなどの可能性があると思います。

Comments

[udon333]

sandboxのみFalseにした際、動作しました! ありがとうございました。(public channelは動きましたが、private channelではまだ動いておりません。。。)
もう一つ伺いたいのですが、public channelとprivate channelの情報を各一つずつsubscribeしたい場合、①一つの関数内でsubscribeのトピックを2つawaitする、または、
②関数をそれぞれ作り、
if __name__ == "__main__":
loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.run_until_complete(main_private())
のように実行する。
という二つの方法を考えたのですが、どちらの方法が合っているか分からず、困っております。今のところ、どちらの方法も試したのですが成功しておりません。何らかのアドバイスをいただけますか?

[t_obara]

https://qiita.com/propella/items/c50a2355b5af2a63b73a
こちらにあるように、複数のcoroutineを並列に動作させる方法に従って修正してみてはいかがでしょうか。

[udon333]

試してみます。websocketは勉強し始めたばかりで全く分からなかったので、とても助かります。
本当にありがとうございました!