The hardware and bandwidth for this mirror is donated by METANET, the Webhosting and Full Service-Cloud Provider.
If you wish to report a bug, or if you are interested in having us mirror your free-software or open-source project, please feel free to contact us at mirror[@]metanet.ch.
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
.
<- etl("mtcars") cars
## 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"
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)
<- src_postgres(dbname = "mtcars", user = "postgres", host = "localhost")
db
# Alternatively, for MySQL
library(RMySQL)
<- src_mysql(dbname = "mtcars", user = "r-user", password = "mypass", host = "localhost")
db <- etl("mtcars", db) cars
At the heart of etl
are three functions:
etl_extract()
, etl_transform()
, and
etl_load()
.
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.
These data may need to be transformed from their raw form to files suitable for importing into SQL (usually CSVs).
%>%
cars etl_transform()
Populate the SQL database with the transformed data.
%>%
cars etl_load()
## Loading 1 file(s) into the database...
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()
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
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.
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},
## }
These binaries (installable software) and packages are in development.
They may not be fully stable and should be used with caution. We make no claims about them.