我正在构建一个WebSocket服务器，其中我希望有一个后台任务，从SQS接收消息，并将其发送到客户端，同时不阻止其余的事件。
但是当我用uvicorn RuntimeWarning: coroutine 'background_task' was never awaited.运行服务器时，
我怎样才能让它连续地向客户端发送数据而不阻塞其余的事件呢？

import socketio
import threading
import json
from sqs_handler import SQSQueue

sio = socketio.AsyncServer(async_mode='asgi')
app = socketio.ASGIApp(sio, static_files={"/": "./"})

@sio.event
async def connect(sid, environ):
    print(sid, "connected")

@sio.event
async def disconnect(sid):
    print(sid, "disconnected")

@sio.event
async def item_removed(sid, data):

    await sio.emit("item_removed", data)

async def background_task():
    queue = SQSQueue()
    while True:
        message = queue.get_next_message_from_sqs()
        data = json.loads(message.body)
        await sio.emit('item_added', data)

background_thread = threading.Thread(target=background_task)
background_thread.daemon = True
background_thread.start()

字符串