磁盘的全局群集对象

Question

(1)我是否可以让集群对象跨机器全局，以便一旦提交作业，该作业就可以提交其他不同的较小作业？

cluster = dispy.JobCluster(compute)

(2)每次调用提交时，“计算”函数会不同吗？

Answer 1

(1)我认为您需要研究一下SharedCluster对象，我对它并不熟悉。

(2)您可以使用if语句并将选择参数传递给compute，在compute函数中创建不同的“函数”

def compute(param):

    if param == 'a':
        'Do something'
    if param == 'b':
        'Do something else'

cluster = dispy.JobCluster(compute)

for i in params:

    cluster.submit(i)