Magento 2: A simple product feed

With Magento 2 Merchant Beta release date getting closer, I decided to dedicate some time to explore the current Magento 2 application that is on Github. Now that I had the chance to actually work with Magento 2 I have to say that it is actually a huge step forward from Magento 1 in my opinion.

In this article I will try to cover a few concepts by coding a task that probably most of you have done a few times – creating a really simple product feed. The goal is to set a cron job that will run every week and create the product feed file that has all the products that were created during the last week. Not a huge task but I think it does a good job of some explaining some new Magento 2 concepts.

This module’s code is also available on my Github account

Creating the module

Since there are no more code pools, we need to create a separate vendor for our module in the app/code folder.


Our module definition is in module.xml file now. We also need to declare the modules that our module depends on:


<?xml version="1.0"?>
<config xmlns:xsi="" xsi:noNamespaceSchemaLocation="../../../../../lib/internal/Magento/Framework/Module/etc/module.xsd">
    <module name="LDusan_Simple" setup_version="0.0.1">
            <module name="Magento_Config"/>
            <module name="Magento_Catalog"/>

After that we should add our module name to the modules array in app/etc/config.php:

return array (
  'modules' => 
  array (
    'LDusan_Simple' => 1,


Let’s define our cronjob. In order for this to work we need to add the Magento 2 cron script to the crontab file, like this (same as in Magento 1):

*/5 * * * * /bin/sh /var/www/magento2/dev/shell/

After that we need to create our module’s crontab.xml file:


<?xml version="1.0"?>
<config xmlns:xsi="" xsi:noNamespaceSchemaLocation="../../Cron/etc/crontab.xsd">
    <group id="default">
        <job name="ldusan_test_export" instance="LDusan\Simple\Model\Cron" method="export">
            <schedule>0 12 * * 0</schedule>

Cron class

We can now start building the actual Cron class that we will use.


namespace LDusan\Simple\Model;

class Cron


Dependency injection

As it has already been mentioned in some articles, in Magento 2 dependencies can be passed through a constructor and they will be automatically resolved using type hints. For this module we need four objects:

  • Product repository to get the products
  • Search Criteria builder (we will need it for using the product repository)
  • Filter Builder
  • Csv class instance from ImportExport module

Our constructor should look like this:


namespace LDusan\Simple\Model;

use Magento\Catalog\Api\ProductRepositoryInterface;
use Magento\Framework\Api\SearchCriteriaBuilder;
use Magento\Framework\Api\FilterBuilder;
use Magento\ImportExport\Model\Export\Adapter\Csv;

class Cron
    protected $productRepository;
    protected $searchCriteriaBuilder;
    protected $filterBuilder;
    protected $csv;

    public function __construct(
        ProductRepositoryInterface $productRepository,
        SearchCriteriaBuilder $searchCriteriaBuilder,
        FilterBuilder $filterBuilder,
        Csv $csv
    ) {
        $this->productRepository = $productRepository;
        $this->searchCriteriaBuilder = $searchCriteriaBuilder;
        $this->filterBuilder = $filterBuilder;
        $this->csv = $csv;

Since we are using the default classes there is no need to define anything in the xml files yet. If we wanted to use some other product repository class that implements ProductRepositoryInterface we could have set that up in di.xml file.

We should always tend to use interfaces for type hinting rather than concrete classes as with interfaces we can easily switch the actual implementation. By using this principle we also make the elements of our system loosely coupled which is a good programming practice.

Export method

We will divide this process in two parts:

  • Retrieving the products from database
  • Writing data to file


public function export()
    $items = $this->getProducts();	


Fetching multiple products from database is slightly different in Magento 2.

Entities are managed through repositories. Repositories are used for managing entity objects and all the common operations that can be done on them such as get, save, getList, delete are in these classes. These methods are defined in interfaces that repository classes implement. This practice will ensure that all the future versions are compatible with the rest of the application.


public function getProducts()
    $filters = [];
    $now = new \DateTime();
    $interval = new \DateInterval('P1W');
    $lastWeek = $now->sub($interval);
    $filters[] = $this->filterBuilder
        ->setValue($lastWeek->format('Y-m-d H:i:s'))
    $searchCriteria = $this->searchCriteriaBuilder->create();
    $searchResults = $this->productRepository->getList($searchCriteria);
    return $searchResults->getItems();

CSV file

We can easily create our csv file with the ImportExport module’s Csv class:


protected function writeToFile($items)
    if (count($items) > 0) {
        $this->csv->setHeaderCols(['id', 'created_at', 'sku']);
            foreach ($items as $item) {
                $this->csv->writeRow(['id'=>$item->getId(), 'created_at' => $item->getCreatedAt(), 'sku' => $item->getSku()]);

Path argument

Here comes the part I like the most about the Magento 2. If you look at the Csv class you’ll see that it extends \Magento\ImportExport\Model\Export\Adapter\AbstractAdapter. Let’s take a look at that class’ constructor:


/* ... */
abstract class AbstractAdapter
     * Constructor
     * @param \Magento\Framework\Filesystem $filesystem
     * @param string|null $destination
     * @throws \Magento\Framework\Exception\LocalizedException
    public function __construct(\Magento\Framework\Filesystem $filesystem, $destination = null)
        $this->_directoryHandle = $filesystem->getDirectoryWrite(DirectoryList::SYS_TMP);
        if (!$destination) {
            $destination = uniqid('importexport_');
        if (!is_string($destination)) {
            throw new \Magento\Framework\Exception\LocalizedException(__('Destination file path must be a string'));

        if (!$this->_directoryHandle->isWritable()) {
            throw new \Magento\Framework\Exception\LocalizedException(__('Destination directory is not writable'));
        if ($this->_directoryHandle->isFile($destination) && !$this->_directoryHandle->isWritable($destination)) {
            throw new \Magento\Framework\Exception\LocalizedException(__('Destination file is not writable'));

        $this->_destination = $destination;


We see that it takes with 2 arguments, the second one is the output file destination. If we want to set a specific path we can easily do so with passing the destination argument using the di.xml file:


<?xml version="1.0"?>
<config xmlns:xsi="" xsi:noNamespaceSchemaLocation="../../../../../../lib/internal/Magento/Framework/ObjectManager/etc/config.xsd">
    <type name="Magento\ImportExport\Model\Export\Adapter\Csv">
            <argument name="destination" xsi:type="string">feeds/product_feed.csv</argument>

As a result of this, the feed will be saved in the file that we defined in the xml file. I think this is generally a good approach and that it provides a cleaner way of extending default functionalities.

There is still work to do

If we did everything correctly we should notice the feed in our system’s temporary folder each Monday morning.

Although the task is accomplished, our module is not finished yet. We need to create some tests that will make sure that everything works smoothly. We’ll leave that for the next article.

Would you like to recommend this article to your friends or colleagues?
Feel free to share.

This article was posted in category Magento 2.

Article "Magento 2: A simple product feed" has 6 responses

Dinesh says: January 7, 2016 at 5:53 am

Thanks For the good article. It works like charm!!!.

I have one Query.
if i want file feed name to dynamic, instead of static. how to achieve this?
any help?

Jaddis says: March 12, 2016 at 2:05 pm

This is very cool. I was wondering if you had any examples of how do something like this for exporting daily orders into CSV?

Lucas Gonzalez says: November 17, 2016 at 5:45 am

Hi, I’ve installed this module successfully in Magento 2.1.2 and can’t do it works… Any csv file is being generated. What could be the problem? Thanks!

Najlae El Azzouzi says: March 29, 2017 at 1:14 pm

Thank you for the module, very helpful.
I tried the same for exporting sales and customers, but I have this error ‘Invalid method Magento\Cron\Model\Schedule::format’ and the status of my cron is on error


Leave a Reply to Abhishek Cancel reply

Your email address will not be published. Required fields are marked *