r - セロリを使用したpyRserveでの並列プログラミング

Question

時系列で構成されるデータ フレームがあります。

日付インデックス | 時系列 1 | 時系列 2 | ... 等々

R を使用して予測関数を実行するために pyRserve を使用しました。

セロリを使って並列処理を実装したい。次のコンテキストでワーカー コードを記述しました。

def pipeR(k #input variable):
    conn = pyRserve.connect(host = 'localhost', port = 6311)
    # OPENING THE CONNECTION TO R

    conn.r.i = k
    # ASSIGNING THE PYTHON VARIABLE TO THAT OF IN THE R ENVIRONMENT

    conn.voideval\('''
    WKR_Func <- forecst(a)
    {
    ...# FORECASTS THE TIMESERIES IN COLUMN a OF THE DATAFRAME
    }
    ''')

    conn.eval('forecst(i)')
    # CALLING THE FUNCTION IN R

group(pipeR.s(k) for k in [...list of column headers...])()

並列処理を実装するには、すべてのワーカー プロセスに対して単一のポートを使用できますか (上記のコードで行ったように、ポート:6311)、または異なるワーカー プロセスに対して異なるポートを使用する必要がありますか??

現在エラーが発生しています

socketConnection のエラー("localhost"、ポート=ポート、サーバー=TRUE、ブロッキング=TRUE、: 接続を開くことができません

Rで。