С CTS вы можете регистрировать операции, связанные с DLI, упрощая поиск, аудит и отслеживание в будущем.
Операция | Тип ресурса | Имя трассировки |
|---|---|---|
Создание базы данных | база данных | createDatabase |
Удаление базы данных | база данных | deleteDatabase |
Изменение владельца базы данных | база данных | alterDatabaseOwner |
Создание таблицы | таблица | createTable |
Удаление таблиц | таблица | deleteTable |
Exporting table data | table | exportData |
Importing table data | table | importData |
Changing the owner of a table | table | alterTableOwner |
Creating a queue | queue | createQueue |
Deleting a queue | queue | deleteQueue |
Granting permissions to a queue | queue | queueAuthorize |
Modifying the CIDR block of a queue | queue | replaceQueue |
Restarting a queue | queue | queueActions |
Scaling out/in a queue | queue | queueActions |
Submitting a job (SQL) | queue | submitJob |
Canceling a job (SQL) | jobs | cancelJob |
Granting DLI the permission to access OBS buckets | obs | authorizeObsBucketsForStream |
Checking SQL syntax | jobs | checkSQL |
Deleting a job | jobs | deleteStreamJob |
Creating a Flink OpenSource SQL job | jobs | createStreamSqlJob |
Updating a Flink OpenSource SQL job | jobs | updateStreamSqlJob |
Deleting Flink jobs in batches | jobs | deleteStreamJobs |
Stopping a Flink job | jobs | stopStreamJobs |
Submitting a Flink job | jobs | submitStreamJobs |
Creating a Flink Jar job | jobs | createStreamJarJob |
Updating a Flink Jar job | jobs | updateStreamJarJob |
Viewing Flink jobs | jobs | checkStreamJob |
Importing a savepoint | jobs | dealSavepoint |
Granting data permissions | authorization | dataAuthorize |
Granting permissions on other projects | authorization | projectDataAuthorize |
Exporting query results | jobs | storeJobResult |
Saving a SQL template | template | createTemplate |
Updating a SQL template | template | updateTemplate |
Deleting a SQL template | template | deleteTemplates |
Creating a Flink template | template | createStreamTemplate |
Updating a Flink template | template | updateStreamTemplate |
Viewing Flink templates | template | checkStreamTemplate |
Deleting a Flink template | template | deleteStreamTemplate |
Creating a datasource authentication and uploading a certificate | datasourceauth | uploadAuthInfo |
Updating datasource authentication information | datasourceauth | updateAuthInfo |
Deleting datasource authentication information | datasourceauth | deleteAuthInfo |
Загрузка пакета ресурсов | ресурс | uploadResources |
Удаление пакета ресурсов | ресурс | deleteResource |
Создание расширенного соединения источника данных | edsconnection | createConnection |
Удаление расширенного соединения источника данных | edsconnection | deleteConnection |
Привязка очереди | edsconnection | associateQueueToConnection |
Отвязка очереди | edsconnection | disassociateQueueToConnection |
Изменение информации о хосте | edsconnection | updateHostInfo |
Добавление маршрута | edsconnection | addRoute |
Удаление маршрута | edsconnection | deleteRoute |
Создание джобы пакетной обработки | джобы | createBatch |
Отмена джобы пакетной обработки | джобы | cancelBatch |
Создание глобальной переменной | переменная | createGlobalVariable |
Удаление глобальной переменной | переменная | deleteGlobalVariable |
Изменение глобальной переменной | переменная | updateGlobalVariable |