最简单去运行一个luigi task的方式是通过luigi命令行工具。
示例代码:
# my_module.py, available in your sys.path
import luigi class MyTask(luigi.Task):
x = luigi.IntParameter()
y = luigi.IntParameter(default=45) def run(self):
print self.x + self.y
在命令行上运行:
(my_python_env)[root@hadoop26 pythonCode]# PYTHONPATH='' luigi --module my_module MyTask --x --y --local-scheduler
或者可以选择这种方式运行:
(my_python_env)[root@hadoop26 pythonCode]# python -m luigi --module my_module MyTask --x --local-scheduler
注意:如果一个参数的名字中含有'_',在命令行中你需要替代为'-'。例如MyTask有一个参数名字是'my_parameter',你需要这么赋值:
luigi --module my_module MyTask --my-parameter 100 --local-scheduler