我正在努力在 python 中使用 concurrent.futures。我正在嘗試迭代大量 S3 對象。由于帳戶、存儲桶和對象的數(shù)量，這可能需要很長時間。比我的 STS 憑據(jù)有效且足夠長的時間我不相信腳本不會被中斷。我希望下面的代碼可以工作，雖然它確實產(chǎn)生了我在使用少量存儲桶測試時正在尋找的輸出，但它僅在完全處理每個存儲桶后寫入已完成的文件和輸出文件，而不是在每次未來返回后寫入。如果它被中斷，則不會寫入已完成的文件和輸出文件。即使已經(jīng)成功處理了許多桶。if __name__ == '__main__':    args_results = parser.parse_args()    completed = open(args_results.completed, 'a+')    out = open(args_results.out, 'a+')      done = getCompleted(args_results.completed)     todo = getBuckets(args_results.todo)    with ThreadPoolExecutor(max_workers=10) as executor:        futures = []        for item in todo:             if item not in done:                account, bucket = item.split('|')                futures.append(executor.submit(getBucketInfo, account, bucket))        for x in as_completed(futures):            result = x.result()            out.write(result + '\n')            completed.write(result['Account'] + '|' + result['Bucket'] + '\n')我是否誤解了 as_completed() 功能應(yīng)該如何工作？