問題タブ [r-doredis]

次のような簡単なセットアップがあります。

R で doRedis パッケージを使用してクラスターをセットアップしようとしています。マシンに「2.8.2101」バージョンの Redis がインストールされています。まず、ローカル マシン (RStudio) でジョブを実行しようとしました。

Redis がサービスとして実行されていることを確認しました (redis-cli ping は「PONG」を返します)

しかし、単純な foreach ループを実行しようとすると、次のエラーが発生します。すべてを再起動しても、同じエラーが発生します。

sprintf("%s:%.0f.env", queue, ID) のエラー: 無効な形式 '%.0f'; 文字オブジェクトには形式 %s を使用

明らかに、順次バージョンは正常に動作します。

助けてください！コメント/ポインタは大歓迎です。さらに情報が必要な場合はお知らせください。

foreach と doRedis を使用する場合、doRedis ワーカーは、処理を開始する前に、すべてのジョブが redis サーバーに到達するまで待機します。すべての前処理が完了する前にそれらを開始することは可能ですか?

私はうまく機能しているイテレータを使用しています-前処理は「ジャストインタイム」に行われ、イテレータが実行されるとジョブデータがサーバーにヒットし始めます。ただし、ワーカーはすべてのジョブがアップロードされるまで待機するだけなので、この動作を利用することはできないようです。

コード例:

この例complex.iterでは時間がかかり、反復する要素が多数あります。process.function()そのため、すべての前処理が完了する前にワーカーが実行を開始できれば素晴らしいことです。complex.iter残念ながら、すべての要素で実行されるまで待機しているようです。

を設定し.inorder=Fました。

この望ましい動作を達成する方法に関する提案はありますか? ありがとう。