Облачная платформаAdvanced

Managing Flink Job Templates

Язык статьи: Русский
Показать оригинал
Страница переведена автоматически и может содержать неточности. Рекомендуем сверяться с английской версией.

Шаблоны Flink включают образцы шаблонов и пользовательские шаблоны. Вы можете изменить существующий образец шаблона, чтобы соответствовать реальным требованиям логики задания, и сэкономить время на редактировании SQL‑запросов. Вы также можете настроить шаблон задания в соответствии со своими привычками и методами, чтобы впоследствии напрямую вызывать или изменять шаблон в новых заданиях.

Управление шаблонами Flink предоставляет следующие функции:

Flink SQL Sample Template

Список шаблонов отображает существующие образцы шаблонов для заданий Flink SQL. Table 1 описывает параметры в списке шаблонов.

Сценарии использования образцов шаблонов могут различаться, что зависит от консоли.

Table 1 Параметры в списке образцов шаблонов Flink SQL

Параметр

Description

Name

Имя шаблона. Значение может содержать до 64 символов. Разрешены только буквы, цифры, дефисы (-) и подчеркивания (_) .

Description

Описание шаблона. Может содержать от 0 до 512 символов.

Operation

Create Job: Создайте задачу напрямую, используя шаблон. После создания задачи система переходит на страницу Edit в разделе Job Management.

Шаблон примера Flink OpenSource SQL

Список шаблонов отображает существующие шаблоны примеров для задач Flink SQL OpenSource. Table 1 описывает параметры в списке шаблонов.

Table 2Параметры в списке шаблонов примеров для задач Flink OpenSource SQL

Parameter

Description

Name

Имя шаблона. Значение может содержать до 64 символов. Разрешены только буквы, цифры, дефисы (-) и подчёркивания (_) .

Description

Описание шаблона. Может содержать от 0 до 512 символов.

Operation

Create Job: Создайте задачу напрямую, используя шаблон. После создания задачи система переходит на страницу Edit в разделе Job Management.

Custom Templates

Список пользовательских шаблонов отображает все Jar job templates. Table 1 описывает параметры в списке пользовательских шаблонов.

Table 3 Параметры в списке пользовательских шаблонов

Parameter

Description

Name

Имя шаблона. Значение может содержать до 64 символов. Разрешены только буквы, цифры, дефисы (-) и подчёркивания (_).

Description

Описание шаблона. Может содержать от 0 до 512 символов.

Created

Время создания шаблона.

Updated

Последнее время изменения шаблона.

Operation

  • Edit: Изменить созданный шаблон.
  • Create Job: Создать задачу напрямую, используя шаблон. После создания задачи система переходит на страницу Edit в разделе Job Management.
  • More:
    • Delete: Удалить созданный шаблон.

Создание шаблона

Вы можете создать шаблон, используя любой из следующих методов:

  • Создание шаблона на странице Template Management
    1. В левой панели навигации консоли управления DLI выберите Job Templates > Flink Templates.
    2. Нажмите Create Template в правом верхнем углу страницы. Отобразится диалоговое окно Create Template.
    3. Укажите Name и Description.
      Table 4 Параметры шаблона

      Параметр

      Описание

      Type

      Template type

      • Flink SQL job template
      • Flink OpenSource SQL job template

      Name

      Имя шаблона. Значение может содержать до 64 символов. Допускаются только буквы, цифры, дефисы (-) и подчёркивания (_).

      ПРИМЕЧАНИЕ:

      Имя шаблона должно быть уникальным.

      Description

      Описание шаблона. Может содержать от 0 до 512 символов.

    4. Нажмите OK, чтобы открыть страницу редактирования.

      Table 5 описывает параметры на странице редактирования шаблона.

      Table 5 Параметры шаблона

      Parameter

      Description

      Name

      Вы можете изменить имя шаблона.

      Description

      Вы можете изменить описание шаблона.

      Saving Mode

      • Save Here: Сохранить изменения в текущем шаблоне.
      • Save as New: Сохранить изменения как новый шаблон.

      SQL statement editing area

      В этой области вы можете вводить подробные SQL‑запросы для реализации бизнес‑логики. Чтобы узнать, как компилировать SQL‑запросы, см. Data Lake Insight SQL Syntax Reference.

      Save

      Сохранить изменения.

      Create Job

      Используйте текущий шаблон для создания задачи.

      Format

      Отформатировать SQL‑запросы. После форматирования SQL‑запросов необходимо снова компилировать их.

      Theme Settings

      Измените размер шрифта, перенос строк и стиль страницы (чёрный или белый фон).

    5. В области редактирования SQL‑запросов введите SQL‑запросы для реализации логики сервиса. Как компилировать SQL‑запросы, см. .
    6. После редактирования SQL‑запроса нажмите Save в правом верхнем углу, чтобы завершить создание шаблона.
    7. (Опционально) Если вам не требуется изменять шаблон, нажмите Create Job в правом верхнем углу, чтобы создать задачу на основе текущего шаблона. Как создать задачу, см. Creating a Flink Jar Job.
  • Создание шаблона на основе существующего шаблона задачи
    1. В левой панели навигации консоли управления DLI выберите Job Templates > Flink Templates. Нажмите вкладку Custom Templates.
    2. В строке, где находится нужный шаблон в списке пользовательских шаблонов, нажмите Edit под Operation, чтобы открыть страницу Edit.
    3. После завершения изменения установите Saving Mode в значение Save as New.
    4. Нажмите Save в правом верхнем углу, чтобы сохранить шаблон как новый.
  • Создание шаблона с использованием созданной задачи
    1. В левой панели навигации консоли управления DLI выберите Job Management > Flink Jobs. Отображается страница Flink Jobs.
    2. Нажмите Create Job в правом верхнем углу. Отображается страница Create Job.
    3. Укажите параметры в соответствии с требованиями.
    4. Нажмите OK, чтобы открыть страницу редактирования.
    5. После компиляции SQL‑оператора нажмите Set as Template.
    6. В отображаемом диалоговом окне Set as Template укажите Name и Description, затем нажмите OK.
  • Создание шаблона на основе существующей задачи
    1. В левой панели навигации консоли управления DLI выберите Job Management > Flink Jobs. Отобразится страница Flink Jobs.
    2. В списке задач найдите строку, содержащую задачу, которую необходимо установить как шаблон, и нажмите Edit в столбце Operation.
    3. After the SQL statement is compiled, click Set as Template.
    4. В отображаемом диалоговом окне Set as Template укажите Name и Description, затем нажмите OK.

Создание задачи на основе шаблона

Вы можете создавать задачи на основе образцовых шаблонов или пользовательских шаблонов.

  1. В левой панели навигации консоли управления DLI выберите Job Templates > Flink Templates.
  2. В списке образцовых шаблонов нажмите Create Job в столбце Operation целевого шаблона. Чтобы узнать, как создать задачу, см. Creating a Flink OpenSource SQL Job и Creating a Flink Jar Job.

Изменение шаблона

После создания пользовательского шаблона вы можете изменить его по необходимости. Образцовый шаблон изменить нельзя, но вы можете просмотреть детали шаблона.

  1. In the left navigation pane of the DLI management console, choose Job Templates > Flink Templates. Click the Custom Templates tab.
  2. In the row where the template you want to modify is located in the custom template list, click Edit in the Operation column to enter the Edit page.
  3. В области редактирования SQL‑запросов измените SQL‑запросы по требованию.
  4. Установите Saving Mode в Save Here.
  5. Нажмите Save в правом верхнем углу, чтобы сохранить изменение.

Удаление шаблона

Вы можете удалить пользовательский шаблон по требованию. Шаблоны образцов удалить нельзя. Удалённые шаблоны нельзя восстановить. Будьте осторожны при выполнении этой операции.

  1. В левой панели навигации консоли управления DLI выберите Job Templates > Flink Templates. Нажмите Custom Templates tab.
  2. В списке пользовательских шаблонов выберите шаблоны, которые нужно удалить, и нажмите Delete в левом верхнем углу списка пользовательских шаблонов.

    В качестве альтернативы вы можете удалить шаблон, выполнив следующие действия: в списке пользовательских шаблонов найдите строку, в которой находится шаблон, который нужно удалить, и нажмите More > Delete в столбце Operation.

  3. В отображаемом диалоговом окне нажмите Yes.