检查flink任务的脚本

检查flink任务的脚本

#!/usr/bin/python

#coding=utf8

import json

import requests

import sys

class checkflink:

def getflinkid(self,name,defs):

try:

self.name = name

res = requests.get(''reader'))

res.encoding = ('utf8')

page = res.text

page = json.loads(page)

# name = 'biz-driver-mgr_info-etl-prod'

name == name

for r in page['applications']:

if str(r['name']) == name:

flinkid = r['applicationId']

res = requests.get('+flinkid + '/jobs', auth=('reader', 'reader'))

res.encoding = ('utf8')

page1 = res.text

page2 = json.loads(page1)

list = page2.get('jobs')

dict = list[0]

defs == 'status'

a = dict.get(defs)

b = str(a)

print(b)

except Exception as e:

print("任务不在运行中，请确认该任务是否被killed")

if __name__ == "__main__":

name = sys.argv[1]

defs = sys.argv[2]

test = checkflink()

#if defs == 'status':

test.getflinkid(name,defs)

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。