import threading


# 后台操作
def async_db_task(func, *args, **kwargs):
    """将数据库操作放到后台线程执行"""
    threading.Thread(target=func, args=args, kwargs=kwargs, daemon=True).start()


import asyncio


async def async_task(func, *args, **kwargs):
    return await asyncio.to_thread(func, *args, **kwargs)


from datetime import datetime

import pytz


def format_datetime(dt: datetime, tz="Asia/Shanghai"):
    if dt.tzinfo is None:
        dt = pytz.UTC.localize(dt)
    tz_obj = pytz.timezone(tz)
    dt = dt.astimezone(tz_obj)
    return dt.strftime("%Y-%m-%d %H:%M:%S")