Spryker DataImport: implement data step

DataImportBusinessFactory.php

<?php

namespace Pyz\Zed\DataImport\Business;

use Pyz\Zed\AkeneoConnector\Business\Model\Attribute\YourWriterStep;
use Spryker\Zed\DataImport\Business\Model\DataImporterInterface;
use Spryker\Zed\DataImport\Business\DataImportBusinessFactory as SprykerDataImportBusinessFactory;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetStepBrokerInterface;

/**
 * @method \Pyz\Zed\DataImport\DataImportConfig getConfig()
 */
class DataImportBusinessFactory extends SprykerDataImportBusinessFactory
{

    protected function createNewDataStep(): YourWriterStep
    {
        return new YourWriterStep();
    }

    protected function getNewDataStepBroker(): DataSetStepBrokerInterface
    {
        $dataSetStepBroker = $this->createTransactionAwareDataSetStepBroker();
        $dataSetStepBroker->addStep($this->createNewDataStep());

        return $dataSetStepBroker;
    }

    protected function createNewImporter(): DataImporterInterface
    {
        $dataImporter = $this->getCsvDataImporterFromConfig($this->getConfig()->getDataImporterConfiguration());

        $dataSetStepBroker = $this->getNewDataStepBroker();

        $dataImporter->addDataSetStepBroker($dataSetStepBroker);

        return $dataImporter;
    }
}

DataImportBusinessFactory::getImporter.php

    public function getImporter(): DataImporterInterface
    {
        $dataImporterCollection = $this->createDataImporterCollection();
        $dataImporterCollection->addDataImporter($this->createNewImporter());

        return $dataImporterCollection;
    }

YourWriterStep.php

namespace Pyz\Zed\AkeneoConnector\Business\Model;

use Spryker\Zed\DataImport\Business\Model\DataImportStep\DataImportStepInterface;
use Spryker\Zed\DataImport\Business\Model\DataSet\DataSetInterface;

class YourWriterStep implements DataImportStepInterface
{
   public function execute(DataSetInterface $dataSet): void
   {
       // process $dataSet and persist data
   }
}