День добрый. У меня есть код, который по очереди вызывает модули. Первый и последний модули должны удалить файлы, оставшиеся после предыдущего запуска.
Со второго по пятый - по очереди: загружают выбранные файлы с ресурса, распаковывают архивы и извлекают указанные файлы, перереформатируют и перекрашивают и, наконец публикуют.
В синхронном режиме все работает, но долго. Есть у меня идея прикрутить туда asyncio, чтоб после загрузки первого из файлов его сразу же подхватывал следующий модуль, но что-то не получается. Помогите, пожалуйста, разобраться. Код:
import sys
import glob, os
import datetime
import time
import subprocess
import asyncio
from concurrent.futures import ALL_COMPLETED
start_time = time.time()
startDate = sys.argv[1]
finishDate = sys.argv[2]
os.system('python3 /var/www/html/algorithm/tiles/delete_all.py')
async def step3():
await step2()
await asyncio.create_subprocess_shell('python3 /var/www/html/algorithm/sentinel_gpgeo/public/walk.py ')
async def step2():
await step1()
await asyncio.create_subprocess_shell('python3 /var/www/html/algorithm/tiles/walk.py ')
async def step1():
await asyncio.create_subprocess_shell('python3 /var/www/html/algorithm/tiles/download_all.py '+startDate+' '+finishDate)
async def step4():
await step3()
await asyncio.create_subprocess_shell('python3 /var/www/html/algorithm/sentinel_gpgeo/public/public.py ')
ioloop = asyncio.get_event_loop()
ioloop.run_until_complete(step3())
ioloop.close()
os.system('python3 /var/www/html/algorithm/tiles/delete_all.py ')
print("--- %s seconds ---" % (time.time() - start_time))
os.system
полностью блокирует поток выполнения, поэтому никакой асинхронности здесь нет