如何使用羊驼的一条小溪？

Question

我试图用流每秒钟/每滴答地获取一个值。我的代码如下：

import alpaca_trade_api as tradeapi

base_url = 'https://paper-api.alpaca.markets'
api_key_id = 'your api key id'
api_secret = 'your api secret'

api = tradeapi.REST(
    key_id=api_key_id, 
    secret_key=api_secret, 
    base_url=base_url,
)

if __name__ == "__main__":
    conn = tradeapi.StreamConn(
          key_id=api_key_id, 
          secret_key=api_secret, 
          base_url=base_url,
    )

    @conn.on(r'A.AAPL$')
    async def handle_second_bar(conn, channel, data):
        print("second", data)

    @conn.on(r'AM.AAPL$')
    async def on_minute_bars(conn, channel, bars):
        print('bars', bars)

    conn.run(['A.AAPL', "AM.AAPL"])

当我运行它时，我得到一个错误，错误是error:root:error，而使用ws-messages:unknown channel A.AAPL（您可能需要指定正确的数据流）。这个问题已经得到解决here，但没有发布解决方案。我怎样才能解决这个问题