|
@@ -28,13 +28,15 @@ class ApplicationCDCMonitor:
|
|
headers = {'Content-Type': 'application/json'}
|
|
headers = {'Content-Type': 'application/json'}
|
|
repo = requests.get(url='http://{}:{}{}?'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
|
|
repo = requests.get(url='http://{}:{}{}?'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
|
|
headers=headers)
|
|
headers=headers)
|
|
|
|
+ errrepo = requests.get(url='http://{}:{}{}?state=error'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
|
|
|
|
+ headers=headers)
|
|
|
|
+ print(errrepo.json(),'---error---')
|
|
message = repo.json()
|
|
message = repo.json()
|
|
print(message)
|
|
print(message)
|
|
for json in message:
|
|
for json in message:
|
|
task_id = json['id']
|
|
task_id = json['id']
|
|
tso = json['checkpoint_tso']
|
|
tso = json['checkpoint_tso']
|
|
error = json['error']
|
|
error = json['error']
|
|
- print(error,'-----',task_id)
|
|
|
|
if error is not None:
|
|
if error is not None:
|
|
|
|
|
|
requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
|
|
requests.delete(url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port,
|