WebSocketでパブリックAPIを用いた値の取得・利用方法について

Question

以前この質問でパブリックAPIで複数のchannelの値を取得し利用する方法については理解できました。
(以前の質問：https://teratail.com/questions/330046）

import websocket
import json
import threading
import time

key = ''
secret = ''

private_channels = ['child_order_events', 'parent_order_events']

class Ticker:

    def __init__(self):
        self.values = dict(closea=0, closeb=0)

    def start(self):
        def on_message(ws, message):
            try:
                rs = json.loads(message)
                channel = rs["params"]["channel"]
                if channel == "lightning_ticker_FX_BTC_JPY":
                    self.values["closea"] = round(float('{ltp}'.format(**(rs["params"]["message"]))))
                elif channel == "lightning_ticker_BTC_JPY":
                    self.values["closeb"] = round(float('{ltp}'.format(**(rs["params"]["message"]))))
                else:
                    print("Got other channel data:", channel, rs)
            except Exception as e:
                print(e)

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

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

        def on_open(ws):
            print("### open ###")
            ws.send(json.dumps([
               {'method': 'subscribe', 'params': {'channel': 'lightning_ticker_FX_BTC_JPY'}},
               {'method': 'subscribe', 'params': {'channel': 'lightning_ticker_BTC_JPY'}},
               {'method': 'subscribe', 'params': {'channel': 'child_order_events'}},
               {'method': 'subscribe', 'params': {'channel': 'parent_order_events'}}               
            ]))

        def run(ws):
            ws.run_forever()

        self.ws = websocket.WebSocketApp("wss://ws.lightstream.bitflyer.com/json-rpc",
                                        on_message=on_message,
                                        on_error=on_error,
                                        on_open =on_open,
                                        on_close=on_close)
        self.th = threading.Thread(target=run,args=(self.ws,))
        self.th.start()

    def shutdown(self):
        self.ws.close()
        
        
ticker = Ticker()
ticker.start()

while True:
    fx = ticker.values["closea"]
    spot = ticker.values["closeb"]        
    
    print(fx)
    print(spot)
    time.sleep(1)

# ticker.shutdown()
print("end")        

今後はAPIキーを用いてプライベートAPIで値を取得したいです。
HTTPはライブラリなどを使ってできるのですが、今回やりたいのはリアルタイムAPIを用いたプライベートの値の取得です。

いろいろ試してみてるのですが、、、認証が入ることによって前回やったパブリックAPIで取得した値との共存させたコードの書き方がわからず困っています。
認証方法についても初心者すぎてわからず、、という感じです。
調べてみようにもどうしらべたらいいかもわからず詰まっている状況です。

       def auth(ws):
           now = int(time.time())
           nonce = token_hex(16)
           sign = hmac.new(self._secret.encode(
               'utf-8'), ''.join([str(now), nonce]).encode('utf-8'), sha256).hexdigest()
           params = {'method': 'auth', 'params': {'api_key': self._key, 'timestamp': now,
                                                  'nonce': nonce, 'signature': sign}, 'id': self._JSONRPC_ID_AUTH}
           ws.send(json.dumps(params))

いろいろ調べてる家庭で認証するような関数をいれ
どこかに認証してAPIキーとかを認証してからチャンネル取得してchild_order_eventsとparent_order_eventsを取得すればいいのかなとためしてみてるのですがどんどんわかんなってきてしまいました。

どのようにすればいいかお伺いできると助かります。

Answer 1

https://bf-lightning-api.readme.io/docs/endpoint-json-rpc
こちらページの利用例のところに、Public ChannelとPrivate Channelの両方を含むコード例が、JavaScriptとC#とRubyの3つで載っているので、これをPythonで書くならば…、と考えてみるといいと思います。