官网说的很清楚了，https://github.com/thieman/dagobah，觉得好用，还是宣传宣传

==What is dagobah==

大家做多任务的调度，通常是用 【 crontab+shel+可执行程序或脚本】，来执行一个定时的多任务调度的负责逻辑，负责点的可能你自己包装一个任务调度脚本（别人读起来用起来很痛苦啊，每个人包装自己的任务调度脚本）

现在跟大家介绍一个 可视化任务调度工具，让你摆脱 crontab+shell ，妈妈再也不也担心我的学习

他也可以支持多机任务调度（还未尝试），使用http通讯或者搭个zookeeper即可（有时间我包装包装贡献上去）

当然OOZIE，zookeeper做分布式流程调度是很好用的，但太重了一些且主要服务于分布式任务

 1. 可视化DAG图的任务调度

     可以通过图形界面直接编辑任务，也可以通过python接口生成以及编辑任务

 2. 多种任务运行机制：

     crontab，任务重试，任务状态发送（邮件）

 3. 只要是shell能运行的命令，都可以写在里面

     task里面写shell命令（可以很长），这样可以调度任何语言编写的程序，

    也可以调度hadoop任务，重启线上服务....  因为他们都是shell

 4. 程序间的如何交互，很多方法，自己搞定咯

    dagobah只做了任何调度，task1,task2运行完后运行task3，

 task1，task2，task3之间的通讯自己来了（通过文件通讯，通过redis，通过http。。。）

示例：task1运行完，2,3准备运行，task4还未调度到

http://s1/mw690/0029mCENgy6IRGfCf7ic0&690

==install==

使用SQLite后端（默认）

使用MongoDB后端

pip install -i http://pypi.v2ex.com/simple pymongo

 

加-i 是为了使用国内下载的镜像
 

http://s4/mw690/0029mCENgy6IRGhgOrN13&690

==> task1.py <==
# coding: gbk
def main():
   outf=open('testfile','a')
   outf.write('11111\n')
   outf.write('2222\n')
   outf.write('adfa\n')
   outf.write('aadfss\n')
   outf.write('eeee\n')
   outf.close()               
if __name__ == '__main__':
   main()

==> task2.py <==
def main():
   print 'task2'
   inf=open('testfile','r')
   outf=open('outfile1','w')
   for line in inf:
       outf.write(line.strip()+'task2\n')
   inf.close()
   outf.close()               

if __name__ == '__main__':
   main()

==> task3.py <==
def main():
   print 'task3'
   inf=open('testfile','r')
   outf=open('outfile2','w')
   for line in inf:
       outf.write(line.strip()+'task3\n')
   inf.close()
   outf.close()               
if __name__ == '__main__':
   main()

==运行任务==

每个任务都可以定制crontab，运行时将变成红色，运行完成变成绿色

http://s7/mw690/0029mCENgy6IRGiWtyS36&690

==查看运行结果==

点击view job，view task即可查看stdout，stderr