tests/testthat/ccasn.R

In hrbrmstr/streamgraph: streamgraph is an htmlwidget for building streamgraph visualizations

library(streamgraph)
library(pbapply)
library(dplyr)
library(data.table)

logs <- list.files("/Users/bob/Development/tiq-test-Winter2015/data/enriched/public_inbound/", full.names=TRUE)

dat <- pblapply(logs, function(x) {
  dat <- read.csv(x)
})

dat2 <- bind_rows(dat)
dat2 <- tbl_dt(dat2)

save(dat2, file="~/Desktop/dat2.rda")

# country view ------------------------------------------------------------

dat2 %>%
  group_by(date, country) %>%
  tally() %>%
  top_n(5, n) -> ccs

streamgraph(ccs, "country", "n") %>%
  sg_axis_x(tick_interval=1, tick_units="weeks", tick_format="%m-%d") %>%
  sg_legend(TRUE, "Country: ")

# asn view ----------------------------------------------------------------

dat2 %>%
  group_by(date, asnumber) %>%
  tally() %>%
  top_n(5, n) %>%
  mutate(asnum=sprintf("AS%d", asnumber)) -> asns

streamgraph(asns, "asnum", "n") %>%
  sg_axis_x(tick_interval=1, tick_units="weeks", tick_format="%m-%d") %>%
  sg_legend(TRUE, "ASN: ")

# ips ---------------------------------------------------------------------

dat2 %>%
  group_by(date, entity) %>%
  tally() %>%
  top_n(5, n) -> ips

streamgraph(ips, "entity", "n") %>%
  sg_axis_x(tick_interval=1, tick_units="weeks", tick_format="%m-%d") %>%
  sg_legend(TRUE, "IPv4: ")