websockets.exceptions 4040(私人使用),原因=耗尽连接--python

发布于 2025-01-12 05:59:57 字数 1356 浏览 4 评论 0原文

我的 websocket 连接上不断收到此错误

websockets.exceptions.ConnectionClosedError: code = 4040 (private use), reason = Draining connection

这是我的代码

bsc = 'wss://speedy-nodes-nyc.moralis.io/123456789/bsc/mainnet/ws'   
web3 = Web3(Web3.WebsocketProvider(bsc))
print(web3.isConnected())

def handle_event(event):
   #Web3.toJSON(event)
   print(Web3.toJSON(event))



async def log_loop(event_filter, poll_interval):
    while True:
        for event in event_filter.get_new_entries():
            handle_event(event)
        await asyncio.sleep(poll_interval)

def main():
    event_filter = myContract.events.Transfer.createFilter(fromBlock="latest")
    #block_filter = web3.eth.filter('latest')
    #tx_filter = web3.eth.filter('pending')
    loop = asyncio.get_event_loop()
    try:
        loop.run_until_complete(
            asyncio.gather(
                #log_loop(block_filter, 2),
                #log_loop(tx_filter, 2)))
                log_loop(event_filter, 2)))
    finally:
        loop.close()

if __name__ == '__main__':
    main()

如果连接在不退出正在运行的脚本的情况下关闭,我如何自动重新连接到我的 websocketprovider?

我知道类似问题已有答案,但没有一个对我有用。

我还知道它在将 javascript 中的选项添加到 websocketprovider 时有效

reconnect: {
auto: true,
delay: 10000,
maxAttempts: 10,
}

我将如何在 python 中使用这些选项?

I keep getting this error on my websocket connection

websockets.exceptions.ConnectionClosedError: code = 4040 (private use), reason = Draining connection

This is my code

bsc = 'wss://speedy-nodes-nyc.moralis.io/123456789/bsc/mainnet/ws'   
web3 = Web3(Web3.WebsocketProvider(bsc))
print(web3.isConnected())

def handle_event(event):
   #Web3.toJSON(event)
   print(Web3.toJSON(event))



async def log_loop(event_filter, poll_interval):
    while True:
        for event in event_filter.get_new_entries():
            handle_event(event)
        await asyncio.sleep(poll_interval)

def main():
    event_filter = myContract.events.Transfer.createFilter(fromBlock="latest")
    #block_filter = web3.eth.filter('latest')
    #tx_filter = web3.eth.filter('pending')
    loop = asyncio.get_event_loop()
    try:
        loop.run_until_complete(
            asyncio.gather(
                #log_loop(block_filter, 2),
                #log_loop(tx_filter, 2)))
                log_loop(event_filter, 2)))
    finally:
        loop.close()

if __name__ == '__main__':
    main()

How can I automatically reconnect to my websocketprovider if the connection closes without exiting my running script?

I know there have been answers to similliar questions but none of them work for me.

I also know that it works when adding options in javascript to the websocketprovider

reconnect: {
auto: true,
delay: 10000,
maxAttempts: 10,
}

How would I use these options in python?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文