Консоль Symfony для cron или расписания задач в сочетании с Task Runner

Для моего проекта мне нужно импортировать 12-15 файлов, от CSV, xml до gz. Поскольку все файлы имеют свою структуру, мне пришлось создать по одной команде для каждого файла. Но это уже слишком и хочется создать общий импорт для всех файлов.

Требования:

• Скрипт импорта должен запускаться каждый час.
• В скрипте импорта должна быть импортированная категория + товары из импорта
• Сценарий импорта должен проверить, соответствует ли моя категория категории импорта, если да, он должен добавить информацию в база данных, если не игнорировать.
• Импорт не должен влиять на веб-сайт, если он выполняется в фоновом режиме.

Что у меня в данный момент в команде:

$handle = fopen("https://example.csv",'r');

$output->writeln('Downloading done!');

$categortArray = [];
$categortA = [];
while (($row = fgetcsv($handle, 4096, ";")) !== FALSE)
{
    $categortA [ $row[21]] = $row[23] ;
    $categortArray [] = $row[21];
}

$output->writeln('Updating category list !');
$result = array_unique($categortArray);
$result2 = array_unique($categortA);

$distributor = $distributor->findByName("Name of Distributor");

foreach ($result as $productgroup) {
    $result = $categoryRepository->findByTitle($productgroup);
    if (empty($result)){
        $category = new Category();
        $category->setTitle($productgroup);
        $category->setDescription("Category Description");
        $category->setDistributor($distributor);

        $categoryService->create($category);
    }
}

foreach ($result2 as $key => $productgroup) {
    $result = $categoryRepository->findByTitle($key);

    /** @var $result Category */
    if ($result !== null) {
        $category = new Category();
        $category->setTitle($productgroup);
        $category->setParent($result[0]);
        $category->setDescription("Name of Distributor");
        $category->setDistributor($distributor);

        $categoryService->create($category);
    }
}

while (($row = fgetcsv($handle, 4096, ";")) !== FALSE)
{

    foreach ($child as $c) {
        if ($c->getTitle() === $row['21']) {
            $product = new Product();
            $product->setName($row[1]);
            $product->setCategory($categoryTop);
            $product->setSku($row[14]);
            $product->setEanUpc($categoryTop->getId());
            $this->productService->save($product);
        }
    }
}

Варианты, о которых я могу думать:

• Вытяните весь сценарий автоматического импорта за одну команду и запускайте его каждые час. Это несложный вариант, но я не думаю, что это лучшее решение, поскольку он потребует много ресурсов на моем сервере.
• Создайте планировщик задач в сочетании с средством запуска задач, где мы регистрируем каждое событие различных шагов, таких как загрузка файла, чтение файла, проверка наличия, проверка соответствия категории, проверка наличия продукта, проверка наличия актуальных запасов продукта и т. д. Для этого варианта я хочу создать свой собственный планировщик + бегун, но у меня нет такого большого опыта и я не знаю, поможет ли это моему проекту. Поскольку каждая задача будет помещена в очередь, это упрощает проверку, если что-то не удается

Также приветствуются советы по моей текущей команде Symfony.