Связаться с намиПодключиться

Загрузка данных из Yandex Object Storage в Yandex Managed Service for PostgreSQL

Статья создана
Обновлена 8 апреля 2025 г.

Примечание

Функциональность загрузки данных из Object Storage в сервисе Data Transfer находится на стадии Preview. Чтобы получить доступ, обратитесь в техническую поддержку или к вашему аккаунт-менеджеру.

Вы можете перенести данные из Yandex Object Storage в таблицу Managed Service for PostgreSQL с помощью сервиса Data Transfer. Для этого:

  1. Подготовьте тестовые данные.
  2. Подготовьте трансфер.
  3. Активируйте трансфер.

Если созданные ресурсы вам больше не нужны, удалите их.

В стоимость поддержки описываемого решения входят:

  • Плата за бакет Object Storage: хранение данных и выполнение операций с ними (см. тарифы Object Storage).
  • Плата за кластер Managed Service for PostgreSQL: использование вычислительных ресурсов, выделенных хостам, и дискового пространства (см. тарифы Managed Service for PostgreSQL).
  • Плата за использование публичных IP-адресов для хостов кластера (см. тарифы Virtual Private Cloud).
  • Плата за каждый трансфер: использование вычислительных ресурсов и количество переданных строк данных (см. тарифы Data Transfer).

Перед началом работы

Подготовьте инфраструктуру:

  1. Создайте кластер-приемник Managed Service for PostgreSQL любой подходящей конфигурации со следующими настройками:

    • Выделен публичный доступ к хостам кластера.
    • Имя БД — db1.
    • Имя пользователя — pg-user.
    • Пароль — <пароль_пользователя>.

  2. Если вы используете группы безопасности в кластере, убедитесь, что они настроены правильно и допускают подключение к нему.

  3. Создайте бакет Yandex Object Storage.

  4. Создайте сервисный аккаунт с именем storage-viewer и ролью storage.viewer. Трансфер будет использовать его для доступа к бакету.

  5. Создайте статический ключ доступа для сервисного аккаунта storage-viewer.

  1. Если у вас еще нет Terraform, установите его.

  2. Получите данные для аутентификации. Вы можете добавить их в переменные окружения или указать далее в файле с настройками провайдера.

  3. Настройте и инициализируйте провайдер. Чтобы не создавать конфигурационный файл с настройками провайдера вручную, скачайте его.

  4. Поместите конфигурационный файл в отдельную рабочую директорию и укажите значения параметров. Если данные для аутентификации не были добавлены в переменные окружения, укажите их в конфигурационном файле.

  5. Скачайте в ту же рабочую директорию файл конфигурации objstorage-to-postgres.tf.

    В этом файле описаны:

    • сеть;
    • подсеть;
    • группа безопасности, необходимая для подключения к кластеру;
    • сервисный аккаунт, который будет использоваться для создания бакета и дальнейшего доступа к нему;
    • секрет Yandex Lockbox, в котором будет храниться статический ключ сервисного аккаунта для настройки эндпоинта-источника;
    • бакет-источник Object Storage;
    • кластер-приемник Managed Service for PostgreSQL;
    • эндпоинт для приемника;
    • трансфер.

  6. Укажите в файле objstorage-to-postgres.tf:

    • folder_id — идентификатор облачного каталога, такой же, как в настройках провайдера.
    • bucket_name — имя бакета в соответствии с правилами именования.
    • pg_password — пароль пользователя PostgreSQL.

  7. Проверьте корректность файлов конфигурации Terraform с помощью команды:

    terraform validate

    Если в файлах конфигурации есть ошибки, Terraform на них укажет.

  8. Создайте необходимую инфраструктуру:

    1. Выполните команду для просмотра планируемых изменений:

      terraform plan

      Если конфигурации ресурсов описаны верно, в терминале отобразится список изменяемых ресурсов и их параметров. Это проверочный этап: ресурсы не будут изменены.

    2. Если вас устраивают планируемые изменения, внесите их:

      1. Выполните команду:

        terraform apply

      2. Подтвердите изменение ресурсов.

      3. Дождитесь завершения операции.

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

Подготовьте тестовые данные

  1. Создайте на рабочей машине demo_data.csv и наполните его тестовыми данными:

    1,Anna
2,Robert
3,Umar
4,Algul
5,Viktor

  2. Загрузите подготовленный файл в бакет Object Storage.

Подготовьте трансфер

  1. Создайте эндпоинт-источник типа Object Storage со следующими настройками:

    • Тип базы данных — Object Storage.

    • Бакет — имя бакета в Object Storage.

    • Идентификатор ключа доступа AWS — открытая часть статического ключа сервисного аккаунта. Если вы создали инфраструктуру с помощью Terraform, скопируйте значение ключа из секрета Yandex Lockbox.

    • Секретный ключ доступа AWS — закрытая часть статического ключа сервисного аккаунта. Если вы создали инфраструктуру с помощью Terraform, скопируйте значение ключа из секрета Yandex Lockbox.

    • Эндпоинт — https://storage.yandexcloud.net.

    • Регион — ru-central1.

    • Формат данных — CSV.

    • Разделитель — знак запятой ,.

    • Таблица — имя CSV-файла в бакете, например demo_data.csv.

    • Схема результирующей таблицы — выберите Вручную и укажите имена полей и тип данных:

      • Id: Int64;
      • Name: UTF8.

    Остальные параметры оставьте по умолчанию.

  2. Создайте эндпоинт-приемник и трансфер:

    1. Создайте эндпоинт-приемник типа PostgreSQL и укажите в нем параметры подключения к кластеру:

      • Тип инсталляции — Кластер Managed Service for PostgreSQL.
      • Кластер Managed Service for PostgreSQL — имя кластера-источника PostgreSQL из выпадающего списка.
      • База данных — db1.
      • Пользователь — pg-user.
      • Пароль — <пароль_пользователя>.

    2. Создайте трансфер типа Копирование, использующий созданные эндпоинты.

    1. Укажите в файле objstorage-to-postgres.tf переменные:

      • source_endpoint_id — значение идентификатора эндпоинта для источника;
      • transfer_enabled – значение 1 для создания трансфера.

    2. Проверьте корректность файлов конфигурации Terraform с помощью команды:

      terraform validate

      Если в файлах конфигурации есть ошибки, Terraform на них укажет.

    3. Создайте необходимую инфраструктуру:

      1. Выполните команду для просмотра планируемых изменений:

        terraform plan

        Если конфигурации ресурсов описаны верно, в терминале отобразится список изменяемых ресурсов и их параметров. Это проверочный этап: ресурсы не будут изменены.

      2. Если вас устраивают планируемые изменения, внесите их:

        1. Выполните команду:

          terraform apply

        2. Подтвердите изменение ресурсов.

        3. Дождитесь завершения операции.

Активируйте трансфер

  1. Активируйте трансфер и дождитесь его перехода в статус Завершен.

  2. Подключитесь к базе данных в кластере-приемнике Managed Service for PostgreSQL.

  3. Выполните запрос:

    SELECT * FROM public."demo_data.csv";
    Пример ответа
     __file_name  | __row_index | Id |  Name  
--------------+-------------+----+--------
demo_data.csv |           1 |  1 | Anna
demo_data.csv |           2 |  2 | Robert
demo_data.csv |           3 |  3 | Umar
demo_data.csv |           4 |  4 | Algul
demo_data.csv |           5 |  5 | Viktor

Данные успешно перенесены.

Удалите созданные ресурсы

Некоторые ресурсы платные. Чтобы за них не списывалась плата, удалите ресурсы, которые вы больше не будете использовать:

  • Трансфер.

  • Эндпоинт-источник.

  • Объекты из бакета.

  • Остальные ресурсы удалите в зависимости от способа их создания:

    1. В терминале перейдите в директорию с планом инфраструктуры.

      Важно

      Убедитесь, что в директории нет Terraform-манифестов с ресурсами, которые вы хотите сохранить. Terraform удаляет все ресурсы, которые были созданы с помощью манифестов в текущей директории.

    2. Удалите ресурсы:

      1. Выполните команду:

        terraform destroy

      2. Подтвердите удаление ресурсов и дождитесь завершения операции.

      Все ресурсы, которые были описаны в Terraform-манифестах, будут удалены.

Предыдущая
Object Storage в MySQL®
Следующая
Object Storage в Greenplum®