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
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
):
Name,Description,Price,Stock
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:
<?php
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();
}
var_dump($rows);
});
And the output will be:
array(
array(
'Name' => 'RaspberryPi',
'Description' => 'Raspberry PI Modell B, 512 MB',
'Price' => 37.05,
'Stock' => 12,
),
array(
'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
vendor/bin/phpunit
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).