CryptoColin commented on issue #8790:
URL:
https://github.com/apache/dolphinscheduler/issues/8790#issuecomment-1064077738
sureļ¼`t_ds_task_definition_log`:
```
id|code|name|version|description|project_code|user_id|task_type|task_params|flag|task_priority|worker_group|environment_code|fail_retry_times|fail_retry_interval|timeout_flag|timeout_notify_strategy|timeout|delay_time|resource_ids|operator|operate_time|create_time|update_time
1,340|4,720,070,430,336|execute_tidb|1||4,266,889,486,116|1|PYTHON|{"resourceList":[{"id":7},{"id":9},{"id":19},{"id":13},{"id":21},{"id":12},{"id":22},{"id":60},{"id":72},{"id":71},{"id":77},{"id":81}],"localParams":[],"rawScript":"from
utils import postgres_functions, mysql_functions, aws_functions,
avro_functions, slack_functions\nimport os\n\nhostname =
os.environ[\"HOSTNAME\"]\nserver = hostname.split(\"-\")[2]\n\nif server ==
\"staging\":\n secret_name =
\"dtsta/eks/dolphinscheduler/app-credentials\"\n\nelif server == \"dev\":\n
secret_name = \"dtdev/eks/dolphinscheduler/app-credentials\"\n\nelif server ==
\"production\":\n secret_name =
\"dtpro/eks/dolphinscheduler/app-credentials\"\n\nregion_name =
\"ap-southeast-1\"\naws_secrets = aws_functions.get_secrets(secret_name,
region_name)\n\n# tidb connection\ntidb_host =
aws_secrets[\"TIDB_BEHAVIOR_HOST\"]\ntidb_port =
int(aws_secrets[\"TIDB_BEHAVIOR_PORT\"])\ntidb_user =
aws_secrets[\"TIDB_BEHAVIOR_USERNAME\"]\ntidb_passwor
d = aws_secrets[\"TIDB_BEHAVIOR_PASSWORD\t\"]\ntidb_database =
aws_secrets[\"TIDB_REPORTING_DATABASE\"]\ntidb_conn =
mysql_functions.create_mysql_connection(tidb_host, tidb_port, tidb_user,
tidb_password, tidb_database)\n\nsql = \"\"\"\nCREATE TABLE IF NOT EXISTS
datawarehouse_reporting.dwd_crypto_fiat_payment_views_bcb_multiple_disbursement_cur\n(\n
vendor_transaction_id text not null\n\t\tprimary key,\n status text ,\n
created_at timestamp(6) NOT NULL,\n currency text ,\n amount
numeric(28,6),\n reference text NOT NULL,\n account_id text NOT NULL,\n
beneficiary_id text NOT NULL,\n multiple_disbursement_found boolean,\n
slack_posted_indicator integer,\n remarks text\n)\n;\n\"\"\"\n\nresults =
mysql_functions.execute_mysql_sql(tidb_conn,
sql)\nprint(results)","dependence":{},"conditionResult":{"successNode":[],"failedNode":[]},"waitStartTimeout":{},"switchResult":{}}|1|2|default|-1|0|1|0|[NULL]|0|0|81,19,21,22,7,71,72,9,12,60,13,77|1|2022-03-03
11:12
:51.265|2022-03-03 11:12:51.265|2022-03-03 11:12:51.265
```
`t_ds_process_task_relation_log`:
```
id|name|project_code|process_definition_code|process_definition_version|pre_task_code|pre_task_version|post_task_code|post_task_version|condition_type|condition_params|operator|operate_time|create_time|update_time
1|[NULL]|4,266,889,486,112|4,266,889,492,900|1|0|0|4,266,889,601,568|1|0|{}|1|2022-01-21
00:00:00.000|2022-01-21 00:00:00.000|2022-01-21 00:00:00.000
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
