我试着写一个Discord bot，它可以将消息从一个服务器转发到另一个服务器。但是我收到了一个警告，它会断开我与discord网关的连接。我读到这是可能的，因为有了tyme.slep（），但是如果没有它，连接总是会中断。据我所知，DDOS保护是由于大量的请求而激活的。

import asyncio
import websocket
import json
from threading import Thread
import discord
import requests
from io import BytesIO
import time
from discord.ext import tasks
# Bot
bot_token = "anything"
user_token = "anything"
client = discord.Client(intents=discord.Intents.default())
# Channels list
f = open('channels.txt', 'r')
channels_file = f.read()
channels_array = channels_file.strip().split('\n')
# Connect func
def send_json_request(ws, request):
    ws.send(json.dumps(request))
def receive_json_response(ws):
    response = ws.recv()
    if response:
        return json.loads(response)
# WebSoket
def on_closed(ws):
    ws.connect("wss://gateway.discord.gg/?v=6&encording=json")
ws = websocket.WebSocket(on_close=on_closed)
ws.connect("wss://gateway.discord.gg/?v=6&encording=json")
def receive_json_response(ws):
    response = ws.recv()
    if response:
        return json.loads(response)
def get_attachment_media(media):
    media_array = []
    for i in media:
        response = requests.get(i['url'])
        im = BytesIO(response.content)
        print(im)
        media_array.append(discord.File(im))
    return media_array
def get_channel(id):
    for i in channels_array:
        if i == id:
            return True
    return False
# Heartbeat
def heartbeat(interval):
    print("Heartbeat begin")
    while True:
        time.sleep(interval)
        heartbeatJSON = {
            "op": 1,
            "d": "null"
        }
        send_json_request(ws, heartbeatJSON)
        print("Heartbeat sent")
@tasks.loop(seconds=0.5)
async def main():
    channel = client.get_channel(anything)
    event = receive_json_response(ws)
    try:
        if event['d']['author']['id'] == 'anything':
            return
        id_channel = event['d']['channel_id']
        id_guild = event['d']['guild_id']
        if  get_channel(id_channel):
            content = event['d']['content']
            attachment_media = get_attachment_media(event['d']['attachments'])
            await channel.send(content, files=attachment_media)
        op_code = event('op')
        if op_code == 11:
            print('Heartbeat recieved')
    except:
        pass
@client.event
async def on_ready():
    event = receive_json_response(ws)
    heartbeat_interval = event['d']['heartbeat_interval'] / 1000
    send_json_request(ws, {
        "op": 2,
        "d": {
            "token": user_token,
            "properties": {
                "$os": 'linux',
                "$browser": 'chrome',
                "$device": 'pc'
            }
        }
    })
    main.start()
    asyncio.run(heartbeat(heartbeat_interval))
client.run(bot_token)