С помощью CTS вы можете регистрировать операции, связанные с DLI, что упрощает поиск, аудит и трассировку в будущем.
Операция | Тип ресурса | Имя трассировки |
|---|---|---|
Создание базы данных | база данных | createDatabase |
Удаление базы данных | база данных | deleteDatabase |
Изменение владельца базы данных | база данных | alterDatabaseOwner |
Создание table | table | createTable |
Удаление table | table | deleteTable |
Экспорт данных table | table | exportData |
Импорт данных table | table | importData |
Изменение владельца table | table | alterTableOwner |
Создание queue | queue | createQueue |
Удаление queue | queue | deleteQueue |
Предоставление прав к queue | queue | queueAuthorize |
Изменение CIDR‑блока queue | queue | replaceQueue |
Перезапуск queue | queue | queueActions |
Масштабирование очереди (увеличение/уменьшение) | queue | queueActions |
Отправка задания (SQL) | queue | submitJob |
Отмена задания (SQL) | jobs | cancelJob |
Предоставление DLI разрешения на доступ к OBS бакетам | obs | authorizeObsBucketsForStream |
Проверка синтаксиса SQL | jobs | checkSQL |
Удаление задания | задания | deleteStreamJob |
Создание задания Flink OpenSource SQL | задания | createStreamSqlJob |
Обновление задания Flink OpenSource SQL | задания | updateStreamSqlJob |
Удаление заданий Flink пакетно | задания | deleteStreamJobs |
Остановка задания Flink | задания | stopStreamJobs |
Отправка Flink job | jobs | submitStreamJobs |
Создание Flink Jar job | jobs | createStreamJarJob |
Обновление Flink Jar job | jobs | updateStreamJarJob |
Просмотр Flink jobs | jobs | checkStreamJob |
Импорт сохраненной точки | jobs | dealSavepoint |
Предоставление прав доступа к данным | авторизация | dataAuthorize |
Предоставление прав доступа к другим проектам | авторизация | projectDataAuthorize |
Экспорт результатов запроса | jobs | storeJobResult |
Сохранение шаблона SQL | шаблон | createTemplate |
Обновление шаблона SQL | шаблон | updateTemplate |
Удаление шаблона SQL | шаблон | deleteTemplates |
Создание шаблона Flink | шаблон | createStreamTemplate |
Обновление шаблона Flink | шаблон | updateStreamTemplate |
Просмотр шаблонов Flink | шаблон | checkStreamTemplate |
Удаление шаблона Flink | шаблон | deleteStreamTemplate |
Создание аутентификации источника данных и загрузка сертификата | datasourceauth | uploadAuthInfo |
Обновление информации об аутентификации источника данных | datasourceauth | updateAuthInfo |
Удаление информации об аутентификации источника данных | datasourceauth | deleteAuthInfo |
Загрузка пакета ресурсов | resource | uploadResources |
Удаление пакета ресурсов | resource | deleteResource |
Создание расширенного соединения источника данных | edsconnection | createConnection |
Удаление расширенного соединения источника данных | edsconnection | deleteConnection |
Привязка очереди | edsconnection | associateQueueToConnection |
Отвязка очереди | edsconnection | disassociateQueueToConnection |
Изменение информации о хосте | edsconnection | updateHostInfo |
Добавление маршрута | edsconnection | addRoute |
Удаление маршрута | edsconnection | deleteRoute |
Создание задачи пакетной обработки | jobs | createBatch |
Отмена задачи пакетной обработки | jobs | cancelBatch |
Создание глобальной переменной | variable | createGlobalVariable |
Удаление глобальной переменной | variable | deleteGlobalVariable |
Изменение глобальной переменной | variable | updateGlobalVariable |
Запрос ресурсов по enterprise project | tms | tmsQueryResources |
Создание elastic resource pool | elasticresourcepool | createElasticResourcePool |
Удаление elastic resource pool | elasticresourcepool | deleteElasticResourcePool |
Обновление elastic resource pool | elasticresourcepool | updateElasticResourcePool |
Привязка очереди к elastic resource pool | elasticresourcepool | associateQueueToElasticResourcePool |
Обновление свойств очереди elastic resource pool | elasticresourcepool | updateElasticResourcePoolQueuePriority |