etl

etl is an R package to facilitate Extract - Transform - Load (ETL) operations for medium data. The end result is generally a populated SQL database, but the user interaction takes place solely within R.

etl is on CRAN, so you can install it in the usual way, then load it.

install.packages("etl")

library(etl)

Instantiate an etl object using a string that determines the class of the resulting object, and the package that provides access to that data. The trivial mtcars database is built into etl.

cars <- etl("mtcars")

## No database was specified so I created one for you at:

## /tmp/Rtmpxgb3In/file1955f5264fb8c.sqlite3

class(cars)

## [1] "etl_mtcars"           "etl"                  "src_SQLiteConnection"
## [4] "src_dbi"              "src_sql"              "src"

Connect to a local or remote database

etl works with a local or remote database to store your data. Every etl object extends a dplyr::src_dbi object. If, as in the example above, you do not specify a SQL source, a local RSQLite database will be created for you. However, you can also specify any source that inherits from dplyr::src_dbi.

Note: If you want to use a database other than a local RSQLite, you must create the mtcars database and have permission to write to it first!

# For PostgreSQL
library(RPostgreSQL)
db <- src_postgres(dbname = "mtcars", user = "postgres", host = "localhost")

# Alternatively, for MySQL
library(RMySQL)
db <- src_mysql(dbname = "mtcars", user = "r-user", password = "mypass", host = "localhost")
cars <- etl("mtcars", db)

At the heart of etl are three functions: etl_extract(), etl_transform(), and etl_load().

Extract

The first step is to acquire data from an online source.

cars %>%
  etl_extract()

## Extracting raw data...

This creates a local store of raw data.

Transform

These data may need to be transformed from their raw form to files suitable for importing into SQL (usually CSVs).

cars %>%
  etl_transform()

Load

Populate the SQL database with the transformed data.

cars %>%
  etl_load()

## Loading 1 file(s) into the database...

Do it all at once

To populate the whole database from scratch, use etl_create.

cars %>%
  etl_create()

## Initializing DB using SQL script init.sqlite

## Extracting raw data...

## Loading 1 file(s) into the database...

You can also update an existing database without re-initializing, but watch out for primary key collisions.

cars %>%
  etl_update()

Do Your Analysis

Now that your database is populated, you can work with it as a src data table just like any other dplyr source.

cars %>%
  tbl("mtcars") %>%
  group_by(cyl) %>%
  summarise(N = n(), mean_mpg = mean(mpg))

## Warning: Missing values are always removed in SQL aggregation functions.
## Use `na.rm = TRUE` to silence this warning
## This warning is displayed once every 8 hours.

## # Source:   SQL [3 x 3]
## # Database: sqlite 3.41.2 [/tmp/Rtmpxgb3In/file1955f5264fb8c.sqlite3]
##     cyl     N mean_mpg
##   <int> <int>    <dbl>
## 1     4    11     26.7
## 2     6     7     19.7
## 3     8    14     15.1

Create your own ETL packages

Suppose you want to create your own ETL package called pkgname. All you have to do is write a package that requires etl, and then you have to write two S3 methods:

etl_extract.etl_pkgname()
etl_load.etl_pkgname()

Please see the “Extending etl” vignette for more information.

Use other ETL packages

macleish : Weather and spatial data from the MacLeish Field Station in Whately, MA.
airlines: On-time flight arrival data from the Bureau of Transportation Statistics
citibike: Municipal bike-sharing system in New York City
nyc311: Phone calls to New York City’s feedback hotline
fec: Campaign contribution data from the Federal Election Commission
imdb: Mirror of the Internet Movie Database

Cite

Please see the full manuscript for additional details.

citation("etl")

## To cite package 'etl' in publications use:
## 
##   Baumer B (2019). "A Grammar for Reproducible and Painless
##   Extract-Transform-Load Operations on Medium Data." _Journal of
##   Computational and Graphical Statistics_, *28*(2), 256-264.
##   doi:10.1080/10618600.2018.1512867
##   <https://doi.org/10.1080/10618600.2018.1512867>.
## 
## A BibTeX entry for LaTeX users is
## 
##   @Article{,
##     title = {A Grammar for Reproducible and Painless Extract-Transform-Load Operations on Medium Data},
##     author = {Benjamin S. Baumer},
##     journal = {Journal of Computational and Graphical Statistics},
##     year = {2019},
##     volume = {28},
##     number = {2},
##     pages = {256--264},
##     doi = {10.1080/10618600.2018.1512867},
##   }

beanumber / etl

readme

etl