import auto_realtime
import auto_store_non_realtime_SCADA_data
import asyncio
import influxdb_api
import influxdb_info
import project_info

# 为了让多个任务并发运行，我们可以用 asyncio.to_thread 分别启动它们
async def main():
    task1 = asyncio.to_thread(auto_realtime.realtime_task)
    task2 = asyncio.to_thread(auto_store_non_realtime_SCADA_data.store_non_realtime_SCADA_data_task)
    await asyncio.gather(task1, task2)


if __name__ == "__main__":
    url = influxdb_info.url
    token = influxdb_info.token
    org_name = influxdb_info.org

    influxdb_api.query_pg_scada_info_realtime(project_info.name)    
    influxdb_api.query_pg_scada_info_non_realtime(project_info.name)

    # 用 asyncio 并发启动两个任务
    asyncio.run(main())