0

我在 Django celery 中有这样的任务：

@task
def file(password, source12, destination):
    subprocess.Popen(['sshpass', '-p', password, 'rsync', '-avz', '--info=progress2', source12, destination], 
                                    stderr=subprocess.PIPE, stdout=subprocess.PIPE).communicate()[0]

我有一个执行上述任务的函数：

@celery.task
@login_required(login_url='/login_backend/') 
def sync(request):
    #user_id = request.session['user_id']
    """Sync the files into the server with the progress bar"""
    if request.method == 'POST':
        choices = request.POST.getlist('choice') 
        for i in choices:
            new_source = source +"/"+ i 
            #b = result.successful()
            #result.get() #Poll the database to get the progress
            start_date1 = datetime.datetime.utcnow().replace(tzinfo=utc)
            source12 = new_source.replace(' ', '') #Remove whitespaces
            file.delay(password, source12, destination)
        return HttpResponseRedirect('/uploaded_files/')
    else:
        return HttpResponseRedirect('/uploaded_files/')

我想向用户显示带有进度的文件传输信息。我想显示file name, remaining time and size of the file正在传输的文件。我怎样才能做到这一点？

4

1 回答 1

0

在这里，您有如何通过 celery 本身传递信息的示例。只需以 AJAX 调用的形式启动上传过程，返回任务的 ID，然后通过 AJAX 询问任务的状态。

要真正知道你在做什么，你需要知道file任务本身的进度。我怀疑你是否可以通过sshpass以其他方式调用子进程然后解析PIPE输出来实现这一点。

.delay当您完成一项任务时，Mind celery 已经为您生成了一个过程。

尝试以块的形式读取目标，rsync 块，然后将文件合并到目标中。这样你就知道你已经转移了多少块。

于 2013-02-05T09:36:22.570 回答