renyupeng 3 年之前
父节点
当前提交
414b5370c3
共有 1 个文件被更改,包括 4 次插入4 次删除
  1. 4 4
      monitor/ApplicationCDCMonitor.py

+ 4 - 4
monitor/ApplicationCDCMonitor.py

@@ -45,15 +45,15 @@ class ApplicationCDCMonitor:
                 backResult = requests.get(
                 backResult = requests.get(
                     url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url, task_id),
                     url='http://{}:{}{}/{}'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url, task_id),
                     headers=headers)
                     headers=headers)
-                backResult = backResult.json
-                if backResult is None:
+                back = backResult.json()
+                if back is None:
                     os.system(
                     os.system(
                         'cd /data/tidb-deploy/cdc-8300/bin; ./cdc cli changefeed create --pd=http://192.168.0.184:2379 '
                         'cd /data/tidb-deploy/cdc-8300/bin; ./cdc cli changefeed create --pd=http://192.168.0.184:2379 '
                         '--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:
-                    print(backResult, '--------2-------')
-                    if backResult['error'] is not None:
+                    print(back, '--------2-------')
+                    if back['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))
                         os.system(
                         os.system(