CSV library to use with Amp PHP framework.

v0.1.3 2019-02-15 14:47 UTC

This package is auto-updated.

Last update: 2023-03-26 11:43:39 UTC


Build Status

CSV library to use with Amp PHP framework. Currently it implements only an iterator which allows to parse CSV rows one at a time.


Require this package using Composer:

composer require webgriffe/amp-csv

Iterator Usage

This library implements an Amp's Iterator which allows to iterate over CSV rows one at a time. Potentially it can parse very large CSV files because only small chunks are kept in memory. See the following example, given this CSV file (path/to/file.csv):

RaspberryPi,"Raspberry PI Modell B, 512 MB",37.05,12
SanDisk Ultra SDHC,SanDisk Ultra SDHC 8 GB 30 MB/s Classe 10,6.92,54

We can have:


use Webgriffe\AmpCsv\Iterator;
use Webgriffe\AmpCsv\Parser;
use Amp\File;

require_once 'vendor/autoload.php';

\Amp\Loop::run(function () {
    $iterator = new Iterator(new Parser(yield File\open('path/to/file.csv', 'rb')));
    while (yield $iterator->advance()) {
        $rows[] = $iterator->getCurrent();

And the output will be:

        'Name' => 'RaspberryPi',
        'Description' => 'Raspberry PI Modell B, 512 MB',
        'Price' => 37.05,
        'Stock' => 12,
        'Name' => 'SanDisk Ultra SDHC',
        'Description' => 'SanDisk Ultra SDHC 8 GB 30 MB/s Classe 10',
        'Price' => 6.92,
        'Stock' => 54,

By default the iterator treats the first line as header and will use the column names to index row values. If a row has a different column number than header an exception will be thrown. If your CSV doesn't have an header as first line you can disable the header parsing by passing false as constructor's second argument:

$iterator = new Iterator(new Parser(yield File\open('path/to/file.csv', 'rb')), false);


To contribute simply fork this repository, do your changes and then propose a pull requests. You should run coding standards check and tests as well:

vendor/bin/phpcs --standard=PSR2 src


This library is under the MIT license. See the complete license in the LICENSE file.


Developed by Webgriffe®. Thanks also to Niklas Keller for his help about converting ReactPHP stream events to an Amp's Iterator (see reactphp/promise-stream#14).