RzmqJobQueue is a JobQueue system for R based on redis and rzmq
I only use it under Ubuntu.
libzmq-dev
apt-get install redis-server
.library(RzmqJobQueue)
init_server(redis.flush=TRUE) # WARNING: it will FLUSH the redis server with index 1
set_init_job( new("job", fun=function() { # some init scripts here
}))
push_job_queue( new("job", fun=base:::mean, argv=list(x = rnorm(100))) )
#! /usr/bin/Rscript
library(RzmqJobQueue)
init_server(redis.flush=FALSE)
wait_worker(path="tcp://*:12345")
#! /usr/bin/Rscript
library(Rbridgewell)
init_worker("tcp://localhost:12345")
while(TRUE) {
do_job("tcp://localhost:12345")
system(sprintf("rm %s/*", tempdir()))
}
library(shiny)
runApp(system.file("shiny", package="RzmqJobQueue"))
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.