共有stderrリダイレクトを使用するマルチセッションの並列化

Question

すべてのエラーメッセージが同じファイルにリダイレクトされるように、マルチセッションの並列処理でRコードを実行しようとしています。ただし、sink()は作成できません。

library(parallel) 
cl <- makePSOCKcluster(2) 
f <- function(){ 
    withr::with_message_sink("messages.txt", Sys.sleep(10)) 
} 
clusterCall(cl = cl, fun = f) 

## Error in checkForRemoteErrors(lapply(cl, recvResult)) : 
## 2 nodes produced errors; first error: Cannot establish message sink when another sink is active. 
## Calls: clusterCall -> checkForRemoteErrors 
## Execution halted 

---

編集

応答のいくつかを考えると、私はこの記事の目的について詳しく説明すべきです。複数の並列バックエンドを持つRパッケージdrakeを開発中です。今日、新しいhook argumentをmake()に実装しました。wraps individual parallel jobsはfunction of the user's choiceです。私が実際に探しているのは、並列バックエンドに関係なくコンソールを消音するhookです。現在の開発バージョンでバックエンドは、

• parallel::mclapply()
• parallel::parLapply()
• base::lapply()適切Makefile
• future::sequential
• future::multicore
• と
• make -j（1つのジョブのparLapply()を介して）
• future.batchtools backends listed here

私はstderrのために働いhookを見つけたと思いました。

hook <- function(){ 
    withr::with_message_sink("messages.txt", Sys.sleep(10)) 
} 

しかし、withr::with_message_sink()は私がparLapply()またはfuture::multisessionバックエンドのために同じファイルに複数の労働者を沈ませません。

Answer 1

あなただけのシンク？：

library(parallel) 
cl <- makePSOCKcluster(2) 
clusterApply(cl, seq_along(cl), function(i) workerID <<- i) 


f <- function(){ 
    outtxt <- paste(workerID, "messages.txt", sep="_") 
    print(outtxt) 
    sink(outtxt) 
    Sys.sleep(10) 
    sink() 
} 
clusterCall(cl = cl, fun = f) 

stopCluster(cl)