Обработка параллелей в R

Question

Здесь я пытаюсь перевести язык текста, используя параллельную обработку в R. Это первый раз, когда я использую параллельную обработку. Мой код:

install.packages("RYandexTranslate") 
    install.packages("textcat") 
    install.packages("plyr") 
    install.packages("parallel") 
    library("RYandexTranslate") 
    library("textcat") 
    library("dplyr") 
    library("parallel") 
    api_key <- "trnsl.1.1.20160707T103515Z.90fa575d702ae81e.6ec78e064eb94a1c00a9bc506c615f223cf0cf5b" 
    cl <- makeCluster(4) 
    Query_L_German <- c("5 euro muenze stempelglanz","2 euro muenzen uebersicht") 
    Par_Conversion <- function(QUery_L_German) 
    { 
     for(i in 1:length(Query_L_German)) 
     { 
     x <- translate(api_key,Query_L_German[i], "de-en")$text 
     return(x) 
     } 
    } 
    a <- length(Query_L_German) 
    parLapply(cl, seq(a), function(i,Query_L_German,Par_Conversion) 
     for(i in 1:length(Query_L_German)){ 
     x <- Par_Conversion(Query_L_German) 
     return(x) 
     }, Query_L_German, Par_Conversion) 

Но, я получаю следующее сообщение об ошибке:

Error in checkForRemoteErrors(val) : 3 nodes produced errors; first error: object 'Query_L_German' not found

Answer 1

При использовании функции parLapply вам необходимо определить функцию и variabels, которые используются в parLapply явно. Это можно сделать, определив varlist в функции clusterExport. Ниже приведено подробное описание question/answer о том, как это сделать и другие вещи с parLapply, если вы хотите больше узнать.

Ваш пример может быть решена путем введения следующей строки перед тем parLapply используется:

clusterExport(cl, varlist = c("api_key","Query_L_German","translate"))