以下程序不输出任何内容,也不抛出任何错误。我是否遗漏了课堂上的run()
方法形式的东西to_S3()
?
class to_S3(luigi.Task):
#The class Mysql_to_tsv converts the data returned by a query on a Mysqldb and stores the data in a tsv in a local file.
def requires(self):
return [Mysql_to_tsv]
def output(self):
return luigi.S3Target("https://s3.amazonaws.com/bucket-name/luigi_attempt.tsv")
该类的output()
方法Mysql_to_tsv()
是:
def output(self):
return luigi.LocalTarget('/Users/user/Desktop/Work/Luigi/test_data.tsv')
请帮助该任务的正确类实现。