12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 |
- 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
|