/
wedata_client.js
1362 lines (1362 loc) · 37.8 KB
/
wedata_client.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.Client = void 0;
/* eslint-disable @typescript-eslint/no-unused-vars */
/*
* Copyright (c) 2018 THL A29 Limited, a Tencent company. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
const abstract_client_1 = require("../../../common/abstract_client");
/**
* wedata client
* @class
*/
class Client extends abstract_client_1.AbstractClient {
constructor(clientConfig) {
super("wedata.tencentcloudapi.com", "2021-08-20", clientConfig);
}
/**
* 创建任务
*/
async CreateTask(req, cb) {
return this.request("CreateTask", req, cb);
}
/**
* 创建任务告警规则
*/
async CreateTaskAlarmRegular(req, cb) {
return this.request("CreateTaskAlarmRegular", req, cb);
}
/**
* 数据集成大屏同步条数统计趋势
*/
async DescribeIntegrationStatisticsRecordsTrend(req, cb) {
return this.request("DescribeIntegrationStatisticsRecordsTrend", req, cb);
}
/**
* 删除集成任务
*/
async DeleteIntegrationTask(req, cb) {
return this.request("DeleteIntegrationTask", req, cb);
}
/**
* 批量终止实例
*/
async KillScheduleInstances(req, cb) {
return this.request("KillScheduleInstances", req, cb);
}
/**
* 开发空间-获取数据开发脚本信息
*/
async GetFileInfo(req, cb) {
return this.request("GetFileInfo", req, cb);
}
/**
* 查询任务脚本
*/
async DescribeTaskScript(req, cb) {
return this.request("DescribeTaskScript", req, cb);
}
/**
* 创建规则模板
*/
async CreateRuleTemplate(req, cb) {
return this.request("CreateRuleTemplate", req, cb);
}
/**
* 实例诊断
*/
async DiagnosePro(req, cb) {
return this.request("DiagnosePro", req, cb);
}
/**
* 实时任务运行指标概览
*/
async DescribeRealTimeTaskMetricOverview(req, cb) {
return this.request("DescribeRealTimeTaskMetricOverview", req, cb);
}
/**
* 获取实例列表
*/
async DescribeScheduleInstances(req, cb) {
return this.request("DescribeScheduleInstances", req, cb);
}
/**
* 仅对任务状态为”调度中“和”已暂停“有效,对所选任务的任务实例进行终止,并停止调度
*/
async BatchStopOpsTasks(req, cb) {
return this.request("BatchStopOpsTasks", req, cb);
}
/**
* 任务状态周期增长趋势
*/
async DescribeTaskByCycleReport(req, cb) {
return this.request("DescribeTaskByCycleReport", req, cb);
}
/**
* 数据质量的概览页面数据监测情况接口
*/
async DescribeDataCheckStat(req, cb) {
return this.request("DescribeDataCheckStat", req, cb);
}
/**
* 批量终止集成任务实例
*/
async BatchKillIntegrationTaskInstances(req, cb) {
return this.request("BatchKillIntegrationTaskInstances", req, cb);
}
/**
* 更新规则组执行策略
*/
async ModifyExecStrategy(req, cb) {
return this.request("ModifyExecStrategy", req, cb);
}
/**
* <p style="color:red;">[注意:该版本只满足广州区部分白名单客户使用]</p>
注册事件监听器
*/
async RegisterEventListener(req, cb) {
return this.request("RegisterEventListener", req, cb);
}
/**
* 建hive表
*/
async CreateHiveTable(req, cb) {
return this.request("CreateHiveTable", req, cb);
}
/**
* 任务运维列表组合条件查询
*/
async DescribeOperateOpsTasks(req, cb) {
return this.request("DescribeOperateOpsTasks", req, cb);
}
/**
* 根据周期类型查询所有实例
*/
async DescribeInstanceByCycle(req, cb) {
return this.request("DescribeInstanceByCycle", req, cb);
}
/**
* 查询集成节点
*/
async DescribeIntegrationNode(req, cb) {
return this.request("DescribeIntegrationNode", req, cb);
}
/**
* 根据周期类型 查询所有任务
*/
async DescribeTaskByCycle(req, cb) {
return this.request("DescribeTaskByCycle", req, cb);
}
/**
* 批量暂停集成任务
*/
async BatchSuspendIntegrationTasks(req, cb) {
return this.request("BatchSuspendIntegrationTasks", req, cb);
}
/**
* 元数据模型-字段基础信息查询接口
*/
async DescribeFieldBasicInfo(req, cb) {
return this.request("DescribeFieldBasicInfo", req, cb);
}
/**
* 删除编排空间工作流
*/
async RemoveWorkflowDs(req, cb) {
return this.request("RemoveWorkflowDs", req, cb);
}
/**
* 获取第三方运行日志
*/
async DescribeThirdTaskRunLog(req, cb) {
return this.request("DescribeThirdTaskRunLog", req, cb);
}
/**
* 查询父目录树,用于工作流、任务定位
*/
async DescribeDsParentFolderTree(req, cb) {
return this.request("DescribeDsParentFolderTree", req, cb);
}
/**
* 继续集成任务
*/
async ResumeIntegrationTask(req, cb) {
return this.request("ResumeIntegrationTask", req, cb);
}
/**
* 重命名任务(任务编辑)
*/
async ModifyTaskName(req, cb) {
return this.request("ModifyTaskName", req, cb);
}
/**
* 离线任务实例运行日志列表
*/
async DescribeInstanceLogList(req, cb) {
return this.request("DescribeInstanceLogList", req, cb);
}
/**
* 提交任务版本
*/
async CreateTaskVersionDs(req, cb) {
return this.request("CreateTaskVersionDs", req, cb);
}
/**
* 批量修改任务责任人
*/
async BatchModifyOpsOwners(req, cb) {
return this.request("BatchModifyOpsOwners", req, cb);
}
/**
* 创建用户自定义函数
*/
async CreateCustomFunction(req, cb) {
return this.request("CreateCustomFunction", req, cb);
}
/**
* 解锁集成任务
*/
async UnlockIntegrationTask(req, cb) {
return this.request("UnlockIntegrationTask", req, cb);
}
/**
* 批量停止集成任务
*/
async BatchStopIntegrationTasks(req, cb) {
return this.request("BatchStopIntegrationTasks", req, cb);
}
/**
* 运维大屏-任务状态分布
*/
async DescribeSchedulerTaskTypeCnt(req, cb) {
return this.request("DescribeSchedulerTaskTypeCnt", req, cb);
}
/**
* 删除项目参数
*/
async DeleteProjectParamDs(req, cb) {
return this.request("DeleteProjectParamDs", req, cb);
}
/**
* 根据项目id 获取项目下所有工作流列表
*/
async DescribeWorkflowListByProjectId(req, cb) {
return this.request("DescribeWorkflowListByProjectId", req, cb);
}
/**
* 创建数据源
*/
async CreateDataSource(req, cb) {
return this.request("CreateDataSource", req, cb);
}
/**
* 实例运维-获取实例日志列表
*/
async DescribeOpsInstanceLogList(req, cb) {
return this.request("DescribeOpsInstanceLogList", req, cb);
}
/**
* 查看事件实例的消费任务
*/
async DescribeEventConsumeTasks(req, cb) {
return this.request("DescribeEventConsumeTasks", req, cb);
}
/**
* 获取离线任务长连接Token
*/
async DescribeOfflineTaskToken(req, cb) {
return this.request("DescribeOfflineTaskToken", req, cb);
}
/**
* 删除规则模板
*/
async DeleteRuleTemplate(req, cb) {
return this.request("DeleteRuleTemplate", req, cb);
}
/**
* 获取待审批列表
*/
async DescribeApproveList(req, cb) {
return this.request("DescribeApproveList", req, cb);
}
/**
* 抢占锁定集成任务
*/
async RobAndLockIntegrationTask(req, cb) {
return this.request("RobAndLockIntegrationTask", req, cb);
}
/**
* 判断集成节点名称是否存在
*/
async CheckIntegrationNodeNameExists(req, cb) {
return this.request("CheckIntegrationNodeNameExists", req, cb);
}
/**
* 告警事件列表
*/
async DescribeAlarmEvents(req, cb) {
return this.request("DescribeAlarmEvents", req, cb);
}
/**
* 批量启动工作流
*/
async RunTasksByMultiWorkflow(req, cb) {
return this.request("RunTasksByMultiWorkflow", req, cb);
}
/**
* 质量报告-质量评分
*/
async DescribeQualityScore(req, cb) {
return this.request("DescribeQualityScore", req, cb);
}
/**
* 数据质量概览页面触发维度分布统计接口
*/
async DescribeRuleDimStat(req, cb) {
return this.request("DescribeRuleDimStat", req, cb);
}
/**
* 生成建hive表的sql
*/
async GenHiveTableDDLSql(req, cb) {
return this.request("GenHiveTableDDLSql", req, cb);
}
/**
* 分页查询任务运行历史
*/
async DescribeTaskRunHistory(req, cb) {
return this.request("DescribeTaskRunHistory", req, cb);
}
/**
* 查看补录计划任务
*/
async DescribeOpsMakePlanTasks(req, cb) {
return this.request("DescribeOpsMakePlanTasks", req, cb);
}
/**
* 数据质量概览页面表排行接口
*/
async DescribeTopTableStat(req, cb) {
return this.request("DescribeTopTableStat", req, cb);
}
/**
* 查询全量函数
*/
async DescribeOrganizationalFunctions(req, cb) {
return this.request("DescribeOrganizationalFunctions", req, cb);
}
/**
* 实例批量置成功
*/
async RunForceSucScheduleInstances(req, cb) {
return this.request("RunForceSucScheduleInstances", req, cb);
}
/**
* 查询目录树
*/
async DescribeDsFolderTree(req, cb) {
return this.request("DescribeDsFolderTree", req, cb);
}
/**
* 无
*/
async SubmitTaskTestRun(req, cb) {
return this.request("SubmitTaskTestRun", req, cb);
}
/**
* 获取审批分类列表
*/
async DescribeApproveTypeList(req, cb) {
return this.request("DescribeApproveTypeList", req, cb);
}
/**
* 规则执行日志查询
*/
async DescribeRuleExecLog(req, cb) {
return this.request("DescribeRuleExecLog", req, cb);
}
/**
* 开发空间-批量删除目录和文件
*/
async DeleteFilePath(req, cb) {
return this.request("DeleteFilePath", req, cb);
}
/**
* 编排空间-创建文件夹
*/
async CreateDsFolder(req, cb) {
return this.request("CreateDsFolder", req, cb);
}
/**
* 获取下游任务信息
*/
async DescribeSuccessorOpsTaskInfos(req, cb) {
return this.request("DescribeSuccessorOpsTaskInfos", req, cb);
}
/**
* 调试运行集成任务
*/
async DryRunDIOfflineTask(req, cb) {
return this.request("DryRunDIOfflineTask", req, cb);
}
/**
* 质量报告-查询质量评分
*/
async DescribeDimensionScore(req, cb) {
return this.request("DescribeDimensionScore", req, cb);
}
/**
* 查询表绑定执行规则组信息
*/
async DescribeRuleGroupTable(req, cb) {
return this.request("DescribeRuleGroupTable", req, cb);
}
/**
* 创建集成任务
*/
async CreateIntegrationTask(req, cb) {
return this.request("CreateIntegrationTask", req, cb);
}
/**
* 查询规则详情
*/
async DescribeRule(req, cb) {
return this.request("DescribeRule", req, cb);
}
/**
* 按补录计划批量终止实例。
*/
async KillOpsMakePlanInstances(req, cb) {
return this.request("KillOpsMakePlanInstances", req, cb);
}
/**
* 数据源详情
*/
async DescribeDataSourceList(req, cb) {
return this.request("DescribeDataSourceList", req, cb);
}
/**
* <p style="color:red;">[注意:该版本只满足广州区部分白名单客户使用]</p>
更新任务
*/
async ModifyTaskInfo(req, cb) {
return this.request("ModifyTaskInfo", req, cb);
}
/**
* 事件管理-触发事件
*/
async TriggerDsEvent(req, cb) {
return this.request("TriggerDsEvent", req, cb);
}
/**
* 运维大屏-实例运行时长排行
*/
async DescribeSchedulerRunTimeInstanceCntByStatus(req, cb) {
return this.request("DescribeSchedulerRunTimeInstanceCntByStatus", req, cb);
}
/**
* 任务状态统计
*/
async DescribeSchedulerTaskCntByStatus(req, cb) {
return this.request("DescribeSchedulerTaskCntByStatus", req, cb);
}
/**
* 更新集成任务
*/
async ModifyIntegrationTask(req, cb) {
return this.request("ModifyIntegrationTask", req, cb);
}
/**
* 查询表得分趋势
*/
async DescribeTableScoreTrend(req, cb) {
return this.request("DescribeTableScoreTrend", req, cb);
}
/**
* 数据集成大屏任务状态分布统计
*/
async DescribeIntegrationStatisticsTaskStatus(req, cb) {
return this.request("DescribeIntegrationStatisticsTaskStatus", req, cb);
}
/**
* 批量运行集成任务
*/
async BatchStartIntegrationTasks(req, cb) {
return this.request("BatchStartIntegrationTasks", req, cb);
}
/**
* 质量报告-修改维度权限
*/
async ModifyDimensionWeight(req, cb) {
return this.request("ModifyDimensionWeight", req, cb);
}
/**
* 查询规则执行结果详情
*/
async DescribeRuleExecDetail(req, cb) {
return this.request("DescribeRuleExecDetail", req, cb);
}
/**
* 离线任务重名校验
*/
async CheckTaskNameExist(req, cb) {
return this.request("CheckTaskNameExist", req, cb);
}
/**
* 根据补录计划和补录任务获取补录实例列表。
*/
async DescribeOpsMakePlanInstances(req, cb) {
return this.request("DescribeOpsMakePlanInstances", req, cb);
}
/**
* 数据源详情
*/
async DescribeDatasource(req, cb) {
return this.request("DescribeDatasource", req, cb);
}
/**
* 数据开发模块-文件夹更新
*/
async ModifyDsFolder(req, cb) {
return this.request("ModifyDsFolder", req, cb);
}
/**
* 通过工作流id,查询工作流详情
*/
async DescribeWorkflowInfoById(req, cb) {
return this.request("DescribeWorkflowInfoById", req, cb);
}
/**
* 任务状态趋势
*/
async DescribeTaskByStatusReport(req, cb) {
return this.request("DescribeTaskByStatusReport", req, cb);
}
/**
* 获取离线任务实例
*/
async GetOfflineInstanceList(req, cb) {
return this.request("GetOfflineInstanceList", req, cb);
}
/**
* 创建离线任务
*/
async CreateOfflineTask(req, cb) {
return this.request("CreateOfflineTask", req, cb);
}
/**
* 更新工作流调度
*/
async ModifyWorkflowSchedule(req, cb) {
return this.request("ModifyWorkflowSchedule", req, cb);
}
/**
* 获取表schema信息
*/
async DescribeTableSchemaInfo(req, cb) {
return this.request("DescribeTableSchemaInfo", req, cb);
}
/**
* 更新质量规则接口
*/
async ModifyRule(req, cb) {
return this.request("ModifyRule", req, cb);
}
/**
* 查询函数类型
*/
async DescribeFunctionTypes(req, cb) {
return this.request("DescribeFunctionTypes", req, cb);
}
/**
* 删除数据源
*/
async DeleteDataSources(req, cb) {
return this.request("DeleteDataSources", req, cb);
}
/**
* 删除集成节点
*/
async DeleteIntegrationNode(req, cb) {
return this.request("DeleteIntegrationNode", req, cb);
}
/**
* 停止集成任务
*/
async StopIntegrationTask(req, cb) {
return this.request("StopIntegrationTask", req, cb);
}
/**
* 获取表元数据list
*/
async DescribeTableMetas(req, cb) {
return this.request("DescribeTableMetas", req, cb);
}
/**
* 实时任务同步速度趋势
*/
async DescribeRealTimeTaskSpeed(req, cb) {
return this.request("DescribeRealTimeTaskSpeed", req, cb);
}
/**
* 获取实例列表
*/
async DescribeInstanceList(req, cb) {
return this.request("DescribeInstanceList", req, cb);
}
/**
* 元数据模型-表基础信息查询接口
*/
async DescribeTableBasicInfo(req, cb) {
return this.request("DescribeTableBasicInfo", req, cb);
}
/**
* 告警接收人详情
*/
async DescribeAlarmReceiver(req, cb) {
return this.request("DescribeAlarmReceiver", req, cb);
}
/**
* 查看任务锁状态信息
*/
async DescribeTaskLockStatus(req, cb) {
return this.request("DescribeTaskLockStatus", req, cb);
}
/**
* 运维大屏-实例状态分布
*/
async DescribeSchedulerInstanceStatus(req, cb) {
return this.request("DescribeSchedulerInstanceStatus", req, cb);
}
/**
* 获取实例运行日志
*/
async DescribeInstanceLog(req, cb) {
return this.request("DescribeInstanceLog", req, cb);
}
/**
* 批量更新集成任务(暂时仅支持批量更新责任人)
*/
async BatchUpdateIntegrationTasks(req, cb) {
return this.request("BatchUpdateIntegrationTasks", req, cb);
}
/**
* 资源管理-批量删除资源文件
*/
async DeleteResourceFiles(req, cb) {
return this.request("DeleteResourceFiles", req, cb);
}
/**
* 批量补数据(创建补录任务)
*/
async CreateOpsMakePlan(req, cb) {
return this.request("CreateOpsMakePlan", req, cb);
}
/**
* 任务运维-批量冻结任务
*/
async FreezeOpsTasks(req, cb) {
return this.request("FreezeOpsTasks", req, cb);
}
/**
* 查询规则组详情接口
*/
async DescribeRuleGroup(req, cb) {
return this.request("DescribeRuleGroup", req, cb);
}
/**
* <p style="color:red;">[注意:该版本只满足广州区部分白名单客户使用]</p>
修改任务脚本
*/
async ModifyTaskScript(req, cb) {
return this.request("ModifyTaskScript", req, cb);
}
/**
* 获取具体实例相关日志信息
*/
async DescribeInstanceLogDetail(req, cb) {
return this.request("DescribeInstanceLogDetail", req, cb);
}
/**
* 编排空间批量操作页面查找全部的文件夹
*/
async FindAllFolder(req, cb) {
return this.request("FindAllFolder", req, cb);
}
/**
* 获取数据库信息
*/
async DescribeDatabaseInfoList(req, cb) {
return this.request("DescribeDatabaseInfoList", req, cb);
}
/**
* 根据层级查找上/下游任务节点
*/
async DescribeDependOpsTasks(req, cb) {
return this.request("DescribeDependOpsTasks", req, cb);
}
/**
* 提交集成任务
*/
async CommitIntegrationTask(req, cb) {
return this.request("CommitIntegrationTask", req, cb);
}
/**
* 删除任务
*/
async DeleteOfflineTask(req, cb) {
return this.request("DeleteOfflineTask", req, cb);
}
/**
* 创建hive表,返回表名称
*/
async CreateHiveTableByDDL(req, cb) {
return this.request("CreateHiveTableByDDL", req, cb);
}
/**
* 编排空间-删除文件夹
*/
async DeleteDsFolder(req, cb) {
return this.request("DeleteDsFolder", req, cb);
}
/**
* 获取资源管理目录树
*/
async DescribeResourceManagePathTrees(req, cb) {
return this.request("DescribeResourceManagePathTrees", req, cb);
}
/**
* 批量置成功集成任务实例
*/
async BatchForceSuccessIntegrationTaskInstances(req, cb) {
return this.request("BatchForceSuccessIntegrationTaskInstances", req, cb);
}
/**
* 查询实时任务日志列表
*/
async DescribeStreamTaskLogList(req, cb) {
return this.request("DescribeStreamTaskLogList", req, cb);
}
/**
* 创建质量规则接口
*/
async CreateRule(req, cb) {
return this.request("CreateRule", req, cb);
}
/**
* 编辑规则模板
*/
async ModifyRuleTemplate(req, cb) {
return this.request("ModifyRuleTemplate", req, cb);
}
/**
* 根据项目ID和事件名称查看事件详情
*/
async DescribeEvent(req, cb) {
return this.request("DescribeEvent", req, cb);
}
/**
* 查询父目录下所有子文件夹+工作流
*/
async DescribeAllByFolderNew(req, cb) {
return this.request("DescribeAllByFolderNew", req, cb);
}
/**
* 质量报告-查询表质量详情
*/
async DescribeTableQualityDetails(req, cb) {
return this.request("DescribeTableQualityDetails", req, cb);
}
/**
* 【过滤条件】
{表名称TableName,支持模糊匹配} {表负责人TableOwnerName,支持模糊匹配} {监控方式MonitorTypes,1.未配置 2.关联生产调度 3.离线周期检测,支持多选} {订阅人ReceiverUin}
【必要字段】
{数据来源DatasourceId}
*/
async DescribeRuleGroupsByPage(req, cb) {
return this.request("DescribeRuleGroupsByPage", req, cb);
}
/**
* 查询表的所有列元数据
*/
async DescribeColumnsMeta(req, cb) {
return this.request("DescribeColumnsMeta", req, cb);
}
/**
* 批量操作页面获取任务列表
*/
async DescribeBatchOperateTask(req, cb) {
return this.request("DescribeBatchOperateTask", req, cb);
}
/**
* 删除质量规则接口
*/
async DeleteRule(req, cb) {
return this.request("DeleteRule", req, cb);
}
/**
* 判断告警规则重名
*/
async CheckAlarmRegularNameExist(req, cb) {
return this.request("CheckAlarmRegularNameExist", req, cb);
}
/**
* 判断集成任务名称是否存在
*/
async CheckIntegrationTaskNameExists(req, cb) {
return this.request("CheckIntegrationTaskNameExists", req, cb);
}
/**
* 分页查询质量规则
*/
async DescribeRulesByPage(req, cb) {
return this.request("DescribeRulesByPage", req, cb);
}
/**
* 删除项目用户
*/
async DeleteProjectUsers(req, cb) {
return this.request("DeleteProjectUsers", req, cb);
}
/**
* 删除文件
*/
async DeleteFile(req, cb) {
return this.request("DeleteFile", req, cb);
}
/**
* 对集成离线任务执行批量补数据操作
*/
async BatchMakeUpIntegrationTasks(req, cb) {
return this.request("BatchMakeUpIntegrationTasks", req, cb);
}
/**
* 保存任务信息
*/
async UploadContent(req, cb) {
return this.request("UploadContent", req, cb);
}
/**
* 查询模板详情
*/
async DescribeRuleTemplate(req, cb) {
return this.request("DescribeRuleTemplate", req, cb);
}
/**
* 任务运维-任务列表 批量启动
*/
async BatchRunOpsTask(req, cb) {
return this.request("BatchRunOpsTask", req, cb);
}
/**
* 【过滤条件】 {模板名称Name,支持模糊匹配} {模板类型type,1.系统模板 2.自定义模板} {质量检测维度QualityDims, 1.准确性 2.唯一性 3.完整性 4.一致性 5.及时性 6.有效性} 【排序字段】 { 引用数排序类型CitationOrderType,根据引用数量排序 ASC DESC}
*/
async DescribeRuleTemplatesByPage(req, cb) {
return this.request("DescribeRuleTemplatesByPage", req, cb);
}
/**
* 更新工作流信息
*/
async ModifyWorkflowInfo(req, cb) {
return this.request("ModifyWorkflowInfo", req, cb);
}
/**
* 数据质量概览页面规则运行情况接口
*/
async DescribeRuleExecStat(req, cb) {
return this.request("DescribeRuleExecStat", req, cb);
}
/**
* 实例批量重跑
*/
async RunRerunScheduleInstances(req, cb) {
return this.request("RunRerunScheduleInstances", req, cb);
}
/**
* 规则组执行结果分页查询接口
*/
async DescribeRuleGroupExecResultsByPage(req, cb) {
return this.request("DescribeRuleGroupExecResultsByPage", req, cb);
}
/**
* 资源管理-删除资源文件
*/
async DeleteResourceFile(req, cb) {
return this.request("DeleteResourceFile", req, cb);
}
/**
* 批量创建任务告警规则
*/
async BatchCreateIntegrationTaskAlarms(req, cb) {
return this.request("BatchCreateIntegrationTaskAlarms", req, cb);
}
/**
* 拉取dag实例
*/
async DagInstances(req, cb) {
return this.request("DagInstances", req, cb);
}
/**
* 修改审批单状态
*/
async ModifyApproveStatus(req, cb) {
return this.request("ModifyApproveStatus", req, cb);
}
/**
* 下载日志文件,返回日志下载URL
*/
async DescribeInstanceLogFile(req, cb) {
return this.request("DescribeInstanceLogFile", req, cb);
}
/**
* 数据集成大屏任务状态统计趋势
*/
async DescribeIntegrationStatisticsTaskStatusTrend(req, cb) {
return this.request("DescribeIntegrationStatisticsTaskStatusTrend", req, cb);
}
/**
* 更新监控状态
*/
async ModifyMonitorStatus(req, cb) {
return this.request("ModifyMonitorStatus", req, cb);
}
/**
* 查询规则组执行策略
*/
async DescribeExecStrategy(req, cb) {
return this.request("DescribeExecStrategy", req, cb);
}
/**
* 列出表血缘信息
*/
async DescribeTableLineage(req, cb) {
return this.request("DescribeTableLineage", req, cb);
}
/**
* 暂停集成任务
*/
async SuspendIntegrationTask(req, cb) {
return this.request("SuspendIntegrationTask", req, cb);
}
/**
* 创建工作流
*/
async CreateWorkflowDs(req, cb) {
return this.request("CreateWorkflowDs", req, cb);
}
/**
* 根据条件查找事件实例
*/
async DescribeEventCases(req, cb) {
return this.request("DescribeEventCases", req, cb);
}
/**
* 获取离线任务实例列表(新)
*/
async GetOfflineDIInstanceList(req, cb) {
return this.request("GetOfflineDIInstanceList", req, cb);
}
/**
* 通过工作流Id删除工作流
*/
async DeleteWorkflowById(req, cb) {
return this.request("DeleteWorkflowById", req, cb);
}
/**
* 查询质量规则列表
*/
async DescribeRules(req, cb) {
return this.request("DescribeRules", req, cb);
}
/**
* 启动集成任务
*/
async StartIntegrationTask(req, cb) {
return this.request("StartIntegrationTask", req, cb);
}
/**
* 锁定集成任务
*/
async LockIntegrationTask(req, cb) {
return this.request("LockIntegrationTask", req, cb);
}
/**
* 提交工作流
*/
async SubmitWorkflow(req, cb) {
return this.request("SubmitWorkflow", req, cb);