|
1 | 1 | import os |
2 | 2 | import logging |
3 | | -import random |
4 | | -import string |
5 | | -import json |
6 | 3 | from contextlib import asynccontextmanager |
7 | 4 | from collections.abc import AsyncGenerator |
8 | 5 | from typing import Dict, Any, Optional, List, Union |
|
14 | 11 | from alibabacloud_dms_enterprise20181101.client import Client as dms_enterprise20181101Client |
15 | 12 | from alibabacloud_tea_openapi import models as open_api_models |
16 | 13 | from alibabacloud_dms_enterprise20181101 import models as dms_enterprise_20181101_models |
17 | | -from alibabacloud_tea_openapi.models import Config |
18 | | -from alibabacloud_tea_util import models as util_models |
19 | 14 |
|
20 | 15 | # --- Global Logger --- |
21 | 16 | logger = logging.getLogger(__name__) |
22 | 17 |
|
23 | | -g_reserved = '''{ |
24 | | - "targetTableMode": "0", |
25 | | - "dbListCaseChangeMode": "default", |
26 | | - "isAnalyzer": false, |
27 | | - "eventMove": false, |
28 | | - "tableAnalyze": false, |
29 | | - "whitelist.dms.online.ddl.enable": false, |
30 | | - "sqlparser.dms.original.ddl": true, |
31 | | - "whitelist.ghost.online.ddl.enable": false, |
32 | | - "sqlparser.ghost.original.ddl": false, |
33 | | - "privilegeMigration": false, |
34 | | - "definer": false, |
35 | | - "privilegeDbList": "[]", |
36 | | - "maxRetryTime": 43200, |
37 | | - "retry.blind.seconds": 600, |
38 | | - "srcSSL": "0", |
39 | | - "srcMySQLType": "HighAvailability", |
40 | | - "destSSL": "0", |
41 | | - "a2aFlag": "2.0", |
42 | | - "channelInfo": "mcp", |
43 | | - "autoStartModulesAfterConfig": "none" |
44 | | -} |
45 | | -''' |
46 | | - |
47 | 18 |
|
48 | 19 | # --- Pydantic Models --- |
49 | 20 | class MyBaseModel(BaseModel): |
|
0 commit comments