我意識到我可能需要使用動態(tài)需求來完成以下任務(wù)，但是我一直無法理解這在實(shí)踐中會是什么樣子。目標(biāo)是使用 Luigi 生成數(shù)據(jù)并將其添加到數(shù)據(jù)庫中，而無需提前知道將生成什么數(shù)據(jù)。以使用 mongodb 為例：import luigifrom uuid import uuid4from luigi.contrib import mongodbimport pymongo# Make up IDs, though in practice the IDs may be generated from an APIclass MakeID(luigi.Task):    def run(self):        with self.output().open('w') as f:            f.write(','.join([str(uuid4()) for e in range(10)]))    # Write the data to file    def output(self):        return luigi.LocalTarget('data.csv')class ToDataBase(luigi.Task):    def requires(self):        return MakeID()    def run(self):        with self.input().open('r') as f:            ids = f.read().split(',')        # Add some fake data to simulate generating new data         count_data = {key: value for value, key in enumerate(ids)}        # Add data to the database        self.output().write(count_data)    def output(self):        # Attempt to read non-existent file to get the IDs to check if task is complete        with self.input().open('r') as f:            valid_ids = f.read().split(',')        client = pymongo.MongoClient('localhost',                                     27017,                                     ssl=False)        return mongodb.MongoRangeTarget(client,                                        'myDB',                                        'myData',                                        valid_ids,                                        'myField')if __name__ == '__main__':    luigi.run()目標(biāo)是獲取數(shù)據(jù)，對其進(jìn)行修改，然后將其添加到數(shù)據(jù)庫中。上面的代碼在運(yùn)行時失敗，因?yàn)閛utput方法在方法ToDataBase之前運(yùn)行，require所以雖然函數(shù)可以訪問輸入，但輸入尚不存在。無論如何，我仍然需要檢查以確保數(shù)據(jù)已添加到數(shù)據(jù)庫中。這個github 問題與我正在尋找的很接近，盡管正如我所提到的，我在實(shí)踐中無法弄清楚這個用例的動態(tài)需求。