96 lines
2.8 KiB
HTTP
96 lines
2.8 KiB
HTTP
@host = 132.126.207.130
|
|
# @host = 132.122.116.142
|
|
@port = 35690
|
|
@username = AxhEbscwsJDbYMH2
|
|
@password = cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4
|
|
@url = http://{{username}}:{{password}}@{{host}}:{{port}}
|
|
@queue-url = {{url}}/hudi_services/queue
|
|
@scheduler-url = {{url}}/hudi_services/service_scheduler
|
|
@web-url = {{url}}/hudi_services/service_web
|
|
@services-url = {{url}}/hudi_services/service_cloud_query
|
|
@api-url = {{url}}/hudi_services/hudi_api
|
|
@exporter-url = {{url}}/hudi_services/service-exporter
|
|
|
|
### 队列名称
|
|
GET {{queue-url}}/queue/names
|
|
|
|
### 队列内容
|
|
GET {{queue-url}}/queue/all?name=compaction-queue-b1
|
|
|
|
### 新增
|
|
POST {{queue-url}}/queue/add/compaction-queue-b1
|
|
Content-Type: application/json
|
|
|
|
{
|
|
"id": "251351dc-36db-4fe3-97d2-9667d7a89559",
|
|
"priority": 1,
|
|
"data": {
|
|
"id": "{{$guid}}",
|
|
"flinkJobId": "1542097996099055616",
|
|
"alias": "acct_acct_item_fs",
|
|
"batch": "ojvfodao_hj",
|
|
"status": "SCHEDULE",
|
|
"comment": "Comment"
|
|
}
|
|
}
|
|
|
|
### 删除
|
|
POST {{queue-url}}/queue/remove_all_id/compaction-queue-test
|
|
Content-Type: application/json
|
|
|
|
[
|
|
"251351dc-36db-4fe3-97d2-9667d7a89559",
|
|
"2b7f29f6-97b5-4363-98a7-a28eaca7d930"
|
|
]
|
|
|
|
### 清空队列
|
|
GET {{queue-url}}/queue/clear?name=compaction-queue-pre
|
|
|
|
### Info
|
|
GET http://{{username}}:{{password}}@132.122.116.146:18166/info/compaction_metrics?flink_job_id=1542097996099055616&alias=acct_acct_item_fs&filter_completes=true
|
|
|
|
### Info
|
|
GET http://{{username}}:{{password}}@132.122.116.150:27510/table/list_compaction_metrics?search_flink_job_id=1542097996099055616&search_alias=acct_acct_item_fs
|
|
|
|
### Query Scheduler
|
|
GET {{scheduler-url}}/schedule/all
|
|
|
|
### schedule table
|
|
GET {{scheduler-url}}/schedule/table?flink_job_id=1740305145625014274&alias=crm_order_ord_prod_inst_attr_test
|
|
|
|
### Query Scheduler
|
|
GET {{web-url}}/cloud/list
|
|
|
|
### Yarn query
|
|
GET http://AxhEbscwsJDbYMH2:cYxg3b4PtWoVD5SjFayWxtnSVsjzRsg4@132.122.116.143:34903/job/list?cluster=a4
|
|
|
|
### Query message id
|
|
GET {{url}}/hudi_services/hudi_api/api/message_id?flink_job_id=1542097984132706304&alias=crm_cfguse_mkt_cam_strategy_rel
|
|
|
|
###
|
|
GET http://132.122.116.149:35680/api/message_id?flink_job_id=1542097984132706304&alias=crm_cfguse_mkt_cam_strategy_rel
|
|
|
|
### Deploy plan
|
|
GET {{web-url}}/cloud/deploy_plan
|
|
|
|
### Get info query services
|
|
GET {{services-url}}/cloud/services?service_name=service-gateway
|
|
|
|
### Get Prometheus targets
|
|
GET {{services-url}}/cloud/targets
|
|
|
|
### Sync status
|
|
GET {{web-url}}/overview/sync_running_status
|
|
|
|
### Get schedule_times
|
|
GET {{scheduler-url}}/schedule/schedule_times
|
|
|
|
### Get message id
|
|
GET {{api-url}}/api/sync_checkpoint_state?flink_job_id=1542097996099055616&alias=acct_acct_item_zs&message_id=861976:46933:-1&publish_time=1705373846898
|
|
|
|
### Test
|
|
GET {{web-url}}/test
|
|
|
|
### 获取未运行的同步任务
|
|
GET {{exporter-url}}/exporter/un_running_flink_job
|