csv-async

This is CSV library to use in asynchronous environment. Implemented API is similar to existing csv crate except that this crate does not support serde.

Some code is borrowed from csv crate (synchronized with version 1.1.3 - May 2020). This package shares CSV parsing routines with csv crate by means of using csv-core crate. Major version of this crate will be kept in sync with major version of csv with which it is API compatible.

CSV files are being read or write by objects of types AsyncReader or AsyncWriter. Library user is responsible for performing conversion from and to string types, which are used by reader's and writer's API. This version of library does not have support for serde serialization.

Library does not contain synchronous reader/writer. If you need it - please use csv crate.

Cargo Features

Features which can be enabled / disabled during program build.

| Feature | Default | Description | |----------|---------|-------------| | tokio | off | Enable to use crate with tokio runtime and libraries |

Enabling tokio feature allows user to use tokio::fs::File and makes AsyncReader (AsyncWriter) to be based on tokio::io::AsyncRead (tokio::io::AsyncWrite). Currently this crate depends on tokio version 0.2.

Without tokio feature, this crate depends only on futures crate and reader (writer) are based on traits futures::io::AsyncRead (futures::io::AsyncWrite), what allows user to use async_std::fs::File.

Example usage:

Sample input file: csv city,region,country,population Southborough,MA,United States,9686 Northbridge,MA,United States,14061 Marlborough,MA,United States,38334 Springfield,MA,United States,152227 Springfield,MO,United States,150443 Springfield,NJ,United States,14976 Concord,NH,United States,42605

```rust use std::error::Error; use std::process; use futures::stream::StreamExt; use async_std::fs::File;

async fn filterbyregion(region:&str, filein:&str, fileout:&str) -> Result<(), Box> { // Function reads CSV file that has column named "region" // at second position (index = 1). // It writes to new file only rows with region equal to passed argument // and remove region column. let mut rdr = csvasync::AsyncReader::fromreader( File::open(filein).await? ); let mut wri = csvasync::AsyncWriter::fromwriter( File::create(fileout).await? ); wri.writerecord(rdr .headers() .await?.intoiter() .filter(|h| *h != "region") ).await?; let mut records = rdr.records(); while let Some(record) = records.next().await { let record = record?; match record.get(1) { Some(reg) if reg == region => wri.writerecord(record .iter() .enumerate() .filter(|(i, _)| *i != 1) .map(|(, s)| s) ).await?, _ => {}, } } Ok(()) }

fn main() { asyncstd::task::blockon(async { if let Err(err) = filterbyregion( "MA", "/tmp/allregions.csv", "/tmp/MAonly.csv" ).await { println!("error running filterbyregion: {}", err); process::exit(1); } }); } ```

Plans

Some ideas for future development: