renyupeng 3 years ago
parent
commit
93d35caa6b
1 changed files with 9 additions and 8 deletions
  1. 9 8
      monitor/ApplicationCDCMonitor.py

+ 9 - 8
monitor/ApplicationCDCMonitor.py

@@ -31,14 +31,15 @@ class ApplicationCDCMonitor:
         errrepo = requests.get(
         errrepo = requests.get(
             url='http://{}:{}{}?state=error'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
             url='http://{}:{}{}?state=error'.format(self.cdc_url, self.cdc_port, self.cdc_changefeeds_url),
             headers=headers)
             headers=headers)
-        errtask = errrepo.json()
-        if errtask is not None:
-            errtask_id = errtask['id']
-            print(errtask, '-----error--------')
-            os.system(
-                '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 '
-                '--changefeed-id={task_id} '.format(task_id=errtask_id))
+        errtasks = errrepo.json()
+        if errtasks is not None:
+            for errtask in errtasks:
+                errtask_id = errtask['id']
+                print(errtask, '-----error--------')
+                os.system(
+                    '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 '
+                    '--changefeed-id={task_id} '.format(task_id=errtask_id))
         message = repo.json()
         message = repo.json()
         # print(message)
         # print(message)
         for json in message:
         for json in message: