25 lines
781 B
Python
25 lines
781 B
Python
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())
|
|
|