def invoke_algo1(param):
    pass
def invoke_algo2(param):
    pass                                       
def main(process_num): 
    # 程序不能停止
    while(True):
        try:   
            # 获取mysql，hbase，kafka，redis等资源
            pass   
        except Exception as e:
            pass
        # 开始准备调度
        try:  
            for message in kafka_consumer:
                try:
                    # kafka 调度参数解析
                    # 取数
                    pass
                except Exception as e:
                    pass
                try:
                    # 数据清洗                        
                    pass
                except Exception as e:
                    pass      
                try:
                    # 算法1 调用  
                    invoke_algo1(param)
                except Exception as e:
                    pass
                try:
                    # 算法2 调用
                    invoke_algo2(param)
                except Exception as e:
                    pass
        except Exception as e:
            pass
        finally:
            pass
if __name__ == '__main__':
   while(True):
        try:
            # 配置参数
            # 分配进程
            # 调用函数
            main()
            pass
        except Exception as e:
            pass
        finally:
            pass