diff --git a/Transferor/Csv/GetHeadersFromMappings.php b/Transferor/Csv/GetHeadersFromMappings.php
new file mode 100644
index 0000000..7d29089
--- /dev/null
+++ b/Transferor/Csv/GetHeadersFromMappings.php
@@ -0,0 +1,27 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Csv;
+
+use GhostUnicorns\CrtCsv\Transferor\Mappings\MappingTypeInterface;
+
+class GetHeadersFromMappings
+{
+    /**
+     * @param MappingTypeInterface[] $mappings
+     * @return string[]
+     */
+    public function execute(array $mappings): array
+    {
+        $headers = [];
+        foreach ($mappings as $mapping) {
+            $headers[] = $mapping->getHead();
+        }
+        return $headers;
+    }
+}
diff --git a/Transferor/CsvTransferor.php b/Transferor/CsvTransferor.php
new file mode 100644
index 0000000..d4348a3
--- /dev/null
+++ b/Transferor/CsvTransferor.php
@@ -0,0 +1,247 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor;
+
+use GhostUnicorns\CrtBase\Api\CrtConfigInterface;
+use GhostUnicorns\CrtBase\Api\TransferorInterface;
+use GhostUnicorns\CrtBase\Exception\CrtException;
+use GhostUnicorns\CrtEntity\Api\EntityRepositoryInterface;
+use GhostUnicorns\CrtCsv\Transferor\Csv\GetHeadersFromMappings;
+use GhostUnicorns\CrtCsv\Transferor\Mappings\MappingTypeInterface;
+use Magento\Framework\Exception\FileSystemException;
+use Magento\Framework\File\Csv as File;
+use Magento\Framework\Filesystem\DirectoryList;
+use Magento\Framework\Filesystem\DriverInterface;
+use Monolog\Logger;
+
+class CsvTransferor implements TransferorInterface
+{
+    /**
+     * @var Logger
+     */
+    private $logger;
+
+    /**
+     * @var string
+     */
+    private $fileName;
+
+    /**
+     * @var string
+     */
+    private $filePath;
+
+    /**
+     * @var MappingTypeInterface[]
+     */
+    private $mappings;
+
+    /**
+     * @var EntityRepositoryInterface
+     */
+    private $entityRepository;
+
+    /**
+     * @var File
+     */
+    private $csv;
+
+    /**
+     * @var DirectoryList
+     */
+    private $directoryList;
+
+    /**
+     * @var GetHeadersFromMappings
+     */
+    private $getHeadersFromMappings;
+
+    /**
+     * @var CrtConfigInterface
+     */
+    private $config;
+
+    /**
+     * @var bool
+     */
+    private $addActivityIdToPath;
+
+    /**
+     * @var DriverInterface
+     */
+    private $driver;
+
+    /**
+     * @param Logger $logger
+     * @param string $fileName
+     * @param string $filePath
+     * @param array $mappings
+     * @param EntityRepositoryInterface $entityRepository
+     * @param File $csv
+     * @param DirectoryList $directoryList
+     * @param GetHeadersFromMappings $getHeadersFromMappings
+     * @param CrtConfigInterface $config
+     * @param DriverInterface $driver
+     * @param bool $addActivityIdToPath
+     * @throws CrtException
+     */
+    public function __construct(
+        Logger $logger,
+        string $fileName,
+        string $filePath,
+        array $mappings,
+        EntityRepositoryInterface $entityRepository,
+        File $csv,
+        DirectoryList $directoryList,
+        GetHeadersFromMappings $getHeadersFromMappings,
+        CrtConfigInterface $config,
+        DriverInterface $driver,
+        bool $addActivityIdToPath = false
+    ) {
+        $this->logger = $logger;
+        $this->fileName = $fileName;
+        $this->filePath = $filePath;
+        $this->mappings = $mappings;
+        foreach ($mappings as $mapping) {
+            if (!$mapping instanceof MappingTypeInterface) {
+                throw new CrtException(__("Invalid type for mappings"));
+            }
+        }
+
+        $this->entityRepository = $entityRepository;
+        $this->csv = $csv;
+        $this->directoryList = $directoryList;
+        $this->getHeadersFromMappings = $getHeadersFromMappings;
+        $this->config = $config;
+        $this->addActivityIdToPath = $addActivityIdToPath;
+        $this->driver = $driver;
+    }
+
+    /**
+     * @param int $activityId
+     * @param string $transferorType
+     * @throws CrtException
+     */
+    public function execute(int $activityId, string $transferorType): void
+    {
+        try {
+            $file = $this->getFileNameWithPath($activityId);
+            $this->emptyFileAndWriteHeaders($file);
+        } catch (FileSystemException $e) {
+            throw new CrtException(__(
+                'activityId:%1 ~ Transferor ~ transferorType:%2 ~ ERROR ~ error:%3',
+                $activityId,
+                $transferorType,
+                $e->getMessage()
+            ));
+        }
+
+        $allActivityEntities = $this->entityRepository->getAllDataRefinedByActivityIdGroupedByIdentifier($activityId);
+        foreach ($allActivityEntities as $entityIdentifier => $entities) {
+            $this->logger->info(__(
+                'activityId:%1 ~ Transferor ~ transferorType:%2 ~ entityIdentifier:%3 ~ START',
+                $activityId,
+                $transferorType,
+                $entityIdentifier
+            ));
+
+            try {
+                $this->appendChildrenFirst($file, $entities);
+            } catch (FileSystemException $e) {
+                $this->logger->error(__(
+                    'activityId:%1 ~ Transferor ~ transferorType:%2 ~ entityIdentifier:%3 ~ ERROR ~ error:%4',
+                    $activityId,
+                    $transferorType,
+                    $entityIdentifier,
+                    $e->getMessage()
+                ));
+
+                if (!$this->config->continueInCaseOfErrors()) {
+                    throw new CrtException(__(
+                        'activityId:%1 ~ Transferor ~ transferorType:%2 ~ entityIdentifier:%3 ~ END ~'.
+                        ' Because of continueInCaseOfErrors = false',
+                        $activityId,
+                        $transferorType,
+                        $entityIdentifier
+                    ));
+                }
+            }
+
+            $this->logger->info(__(
+                'activityId:%1 ~ Transferor ~ transferorType:%2 ~ entityIdentifier:%3 ~ END',
+                $activityId,
+                $transferorType,
+                $entityIdentifier
+            ));
+        }
+    }
+
+    /**
+     * @param int $activityId
+     * @return string
+     * @throws FileSystemException
+     */
+    private function getFileNameWithPath(int $activityId): string
+    {
+        $fileName = $this->fileName . '_' . (string)$activityId . '_01.csv';
+        $directory = $this->directoryList->getPath(\Magento\Framework\App\Filesystem\DirectoryList::ROOT);
+        $path = $directory . DIRECTORY_SEPARATOR . $this->filePath . DIRECTORY_SEPARATOR;
+        if ($this->addActivityIdToPath) {
+            $path .= $activityId . DIRECTORY_SEPARATOR;
+            $this->driver->createDirectory($path, 0755);
+        }
+        $path .= $fileName;
+        return $path;
+    }
+
+    /**
+     * @param string $file
+     * @throws FileSystemException
+     */
+    private function emptyFileAndWriteHeaders(string $file)
+    {
+        $headers = [$this->getHeadersFromMappings->execute($this->mappings)];
+        $this->csv->appendData($file, $headers, 'w+');
+    }
+
+    /**
+     * @param string $file
+     * @param array $entities
+     */
+    /** @codingStandardsIgnoreStart */
+    protected function appendChildrenFirst(string $file, array $entities)
+    {
+        //redy to extend
+    }
+    /** @codingStandardsIgnoreEnd  */
+
+    /**
+     * @param array $entities
+     * @return array[]
+     * @throw CrtException
+     */
+    protected function getData(array $entities): array
+    {
+        $data = [];
+        foreach ($this->mappings as $mapping) {
+            $data[] = $mapping->execute($entities);
+        }
+        return [$data];
+    }
+
+    /**
+     * @param string $file
+     * @param array $data
+     * @throws FileSystemException
+     */
+    protected function appendToFile(string $file, array $data)
+    {
+        $this->csv->appendData($file, $data, 'a+');
+    }
+}
diff --git a/Transferor/Mappings/Blank.php b/Transferor/Mappings/Blank.php
new file mode 100644
index 0000000..445eb2a
--- /dev/null
+++ b/Transferor/Mappings/Blank.php
@@ -0,0 +1,43 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings;
+
+class Blank implements MappingTypeInterface
+{
+    /**
+     * @var string
+     */
+    private $head;
+
+    /**
+     * @param string $head
+     */
+    public function __construct(
+        string $head
+    ) {
+        $this->head = $head;
+    }
+
+    /**
+     * @param array $data
+     * @return string
+     */
+    public function execute(array $data): string
+    {
+        return '';
+    }
+
+    /**
+     * @return string
+     */
+    public function getHead(): string
+    {
+        return $this->head;
+    }
+}
diff --git a/Transferor/Mappings/Fixed.php b/Transferor/Mappings/Fixed.php
new file mode 100644
index 0000000..085a619
--- /dev/null
+++ b/Transferor/Mappings/Fixed.php
@@ -0,0 +1,51 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings;
+
+class Fixed implements MappingTypeInterface
+{
+    /**
+     * @var string
+     */
+    private $head;
+
+    /**
+     * @var string
+     */
+    private $value;
+
+    /**
+     * @param string $head
+     * @param string $value
+     */
+    public function __construct(
+        string $head,
+        string $value
+    ) {
+        $this->head = $head;
+        $this->value = $value;
+    }
+
+    /**
+     * @param array $data
+     * @return string
+     */
+    public function execute(array $data): string
+    {
+        return $this->value;
+    }
+
+    /**
+     * @return string
+     */
+    public function getHead(): string
+    {
+        return $this->head;
+    }
+}
diff --git a/Transferor/Mappings/Json/DirectPath.php b/Transferor/Mappings/Json/DirectPath.php
new file mode 100644
index 0000000..faf4dfa
--- /dev/null
+++ b/Transferor/Mappings/Json/DirectPath.php
@@ -0,0 +1,64 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings\Json;
+
+use GhostUnicorns\CrtBase\Exception\CrtException;
+use GhostUnicorns\CrtCsv\Model\DotConvention;
+use GhostUnicorns\CrtCsv\Transferor\Mappings\MappingTypeInterface;
+
+class DirectPath implements MappingTypeInterface
+{
+    /**
+     * @var string
+     */
+    private $head;
+
+    /**
+     * @var string
+     */
+    private $path;
+
+    /**
+     * @var DotConvention
+     */
+    private $dotConvention;
+
+    /**
+     * @param string $head
+     * @param string $path
+     * @param DotConvention $dotConvention
+     */
+    public function __construct(
+        string $head,
+        string $path,
+        DotConvention $dotConvention
+    ) {
+        $this->head = $head;
+        $this->path = $path;
+        $this->dotConvention = $dotConvention;
+    }
+
+    /**
+     * @param array $data
+     * @return string
+     * @throws CrtException
+     */
+    public function execute(array $data): string
+    {
+        return (string)$this->dotConvention->getValue($data, $this->path);
+    }
+
+    /**
+     * @return string
+     */
+    public function getHead(): string
+    {
+        return $this->head;
+    }
+}
diff --git a/Transferor/Mappings/Json/ImplodePath.php b/Transferor/Mappings/Json/ImplodePath.php
new file mode 100644
index 0000000..3aee3bb
--- /dev/null
+++ b/Transferor/Mappings/Json/ImplodePath.php
@@ -0,0 +1,95 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings\Json;
+
+use GhostUnicorns\CrtBase\Exception\CrtException;
+use GhostUnicorns\CrtCsv\Model\DotConvention;
+use GhostUnicorns\CrtCsv\Transferor\Mappings\MappingTypeInterface;
+
+class ImplodePath implements MappingTypeInterface
+{
+    /**
+     * @var string
+     */
+    private $head;
+
+    /**
+     * @var string
+     */
+    private $path;
+
+    /**
+     * @var DotConvention
+     */
+    private $dotConvention;
+
+    /**
+     * @var string
+     */
+    private $separator;
+
+    /**
+     * @param string $head
+     * @param string $path
+     * @param string $separator
+     * @param DotConvention $dotConvention
+     */
+    public function __construct(
+        DotConvention $dotConvention,
+        string $head,
+        string $path,
+        string $separator = ','
+    ) {
+        $this->dotConvention = $dotConvention;
+        $this->head = $head;
+        $this->path = $path;
+        $this->separator = $separator;
+    }
+
+    /**
+     * @param array $data
+     * @return string
+     * @throws CrtException
+     */
+    public function execute(array $data): string
+    {
+        $identifiers = $this->dotConvention->getAll($this->path);
+
+        $results = [];
+        $result = '';
+        $value = $data;
+        end($identifiers);
+        $lastKey = key($identifiers);
+        foreach ($identifiers as $key => $identifier) {
+            if (!array_key_exists($identifier, $value)) {
+                throw new CrtException(__('Non existing field %1', $this->path));
+            }
+            $value = $value[$identifier];
+
+            if ($lastKey === $key) {
+                $results = $value;
+            }
+        }
+
+        foreach ($results as $key => $value) {
+            $result .= $this->separator . $key . '=' . $value;
+        }
+
+        $result = ltrim($result, $this->separator);
+        return $result;
+    }
+
+    /**
+     * @return string
+     */
+    public function getHead(): string
+    {
+        return $this->head;
+    }
+}
diff --git a/Transferor/Mappings/Json/Path.php b/Transferor/Mappings/Json/Path.php
new file mode 100644
index 0000000..34b80cc
--- /dev/null
+++ b/Transferor/Mappings/Json/Path.php
@@ -0,0 +1,64 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+declare(strict_types=1);
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings\Json;
+
+use GhostUnicorns\CrtBase\Exception\CrtException;
+use GhostUnicorns\CrtCsv\Model\DotConvention;
+use GhostUnicorns\CrtCsv\Transferor\Mappings\MappingTypeInterface;
+
+class Path implements MappingTypeInterface
+{
+    /**
+     * @var string
+     */
+    private $head;
+
+    /**
+     * @var string
+     */
+    private $path;
+
+    /**
+     * @var DotConvention
+     */
+    private $dotConvention;
+
+    /**
+     * @param string $head
+     * @param string $path
+     * @param DotConvention $dotConvention
+     */
+    public function __construct(
+        string $head,
+        string $path,
+        DotConvention $dotConvention
+    ) {
+        $this->head = $head;
+        $this->path = $path;
+        $this->dotConvention = $dotConvention;
+    }
+
+    /**
+     * @param array $data
+     * @return string
+     * @throws CrtException
+     */
+    public function execute(array $data): string
+    {
+        return (string)$this->dotConvention->getValue($data, $this->path);
+    }
+
+    /**
+     * @return string
+     */
+    public function getHead(): string
+    {
+        return $this->head;
+    }
+}
diff --git a/Transferor/Mappings/MappingTypeInterface.php b/Transferor/Mappings/MappingTypeInterface.php
new file mode 100644
index 0000000..0aa6524
--- /dev/null
+++ b/Transferor/Mappings/MappingTypeInterface.php
@@ -0,0 +1,21 @@
+<?php
+/*
+  * Copyright © Ghost Unicorns snc. All rights reserved.
+ * See LICENSE for license details.
+ */
+
+namespace GhostUnicorns\CrtCsv\Transferor\Mappings;
+
+interface MappingTypeInterface
+{
+    /**
+     * @return string
+     */
+    public function getHead(): string;
+
+    /**
+     * @param array $data
+     * @return string
+     */
+    public function execute(array $data): string;
+}