|
@@ -52,6 +52,7 @@ class ApplicationCDCMonitor:
|
|
'--changefeed-id={task_id} '.format(task_id=task_id))
|
|
'--changefeed-id={task_id} '.format(task_id=task_id))
|
|
else:
|
|
else:
|
|
result = backResult.json()
|
|
result = backResult.json()
|
|
|
|
+ print(result)
|
|
if result['error'] is not None:
|
|
if result['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,
|
|
self.cdc_changefeeds_url, task_id))
|
|
self.cdc_changefeeds_url, task_id))
|
|
@@ -61,7 +62,7 @@ class ApplicationCDCMonitor:
|
|
'--sink-uri="mysql://data:hcst@2021@139.186.27.96:3390" --config ../conf/{task_id}.toml '
|
|
'--sink-uri="mysql://data:hcst@2021@139.186.27.96:3390" --config ../conf/{task_id}.toml '
|
|
'--changefeed-id={task_id} '.format(task_id=task_id))
|
|
'--changefeed-id={task_id} '.format(task_id=task_id))
|
|
else:
|
|
else:
|
|
- logging.info('创新创建没有问题')
|
|
|
|
|
|
+ logging.info('新创建没有问题')
|
|
else:
|
|
else:
|
|
logging.info("无异常")
|
|
logging.info("无异常")
|
|
|
|
|