Создание соединения#

Последовательность выполнения#

Для создания соединения:

1. Нажмите Создать соединение над списком всех соединений.

   

2. Заполните поля в открывшемся окне Создание соединения.

   

   • тип — тип соединения: база данных или очередь;

   • наименование соединения — название соединения;

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

   • описание — описание соединения;

   • теги;

   • драйвер — поле недоступно для редактирования;

   • поле Опции — редактор JSON.

3. Пропишите в поле Опции:

   1. Для соединения источника:

      • URL — адрес БД;

      • backup URL — адрес резервной БД;

      • слот;

      • имя публикации;

      • путь до драйвера.

      Например:

         {
         "url": "jdbc:postgresql://***/postgres", 
         "backup_url": "jdbc:postgresql://***/postgres", 
         "slot": "slot", 
         "publication_names": "publication" 
         "driver": "org.postgresql.Driver"
         }
      

      Параметры соединения с БД Источника

      Параметр	Обязательность	Тип	Описание	По умолчанию
      url	Да	string	Адрес БД, для кластера указываются адреса через запятую
      backup_url	Нет	string	Адрес резервной БД, для кластера указываются адреса через запятую	«»
      slot	Да	string	Имя слота
      publication_names	Да	string	Имя публикации
      driver	Да	string	Путь до драйвера
      login	Нет	string	Логин БД	«»
      password	Нет	string	Пароль БД	«»
      disallowed_origins	Нет	string	Черный список для Active-Active	[]
      allowed_origins	Нет	string	Белый список для Active-Active	[]

      

   2. Для очереди:

      • адреса брокеров Kafka;

      • протокол безопасной связи;

      • имя топика Kafka;

      • путь к хранилищу с сертификатом;

      • путь к хранилищу с приватным ключом;

      • пароль к хранилищу ключей.

      Например:

         {
         "bootstrap.servers": "***",
         "security.protocol": "SSL",
         "topic.name": "***", 
         "ssl.endpoint.identification.algorithm": "", 
         "ssl.truststore.location": "/etc/kafka-jks/kafka.jks", 
         "ssl.keystore.location": "/etc/kafka-jks/kafka.jks", 
         "ssl.keystore.password": "***" 
         }
      

      Параметры соединения с Kafka

      Параметр	Обязательность	Тип	Описание	По умолчанию
      bootstrap.servers	Да	string	Адреса брокеров Kafka
      security.protocol	Нет	string	Протокол безопасной связи	«SSL»
      topic.name	Да	string	Имя топика
      ssl.endpoint.identification.algorithm	Нет	string	Алгоритм идентификации	«»
      ssl.truststore.location	Нет	string	Путь к хранилищу с сертификатом	«/etc/kafka-jks/kafka.jks»
      ssl.keystore.location	Нет	string	Путь к хранилищу с приватным ключом	«/etc/kafka-jks/kafka.jks»
      ssl.keystore.password	Нет	string	Пароль к хранилищу ключей	«»
      batch.size	Нет	int	Размер пакета записей в Kafka Producer	16384
      max.poll.records	Нет	int	Размер пакета записей в Kafka consumer	500

      Параметры delivery.timeout.ms и request.timeout.ms в Platform V GraDeLy 2.3.1 не будут применяться, их функционал реализован в обработчике ошибок CONNECTION_ERROR.

      

   3. Для соединения приемника:

      • URL — адрес БД;

      • backup URL — адрес резервной БД;

      • путь до драйвера.

      Например:

         {
         "url": "jdbc:postgresql://***/postgres",
         "backup_url": "jdbc:postgresql://***/postgres",
         "driver": "org.postgresql.Driver"
         }
      

   Параметры соединения с БД Приемника

   Параметр	Обязательность	Тип	Описание	По умолчанию
   url	Да	string	Адрес БД, для кластера указываются адреса через запятую
   backup_url	Нет	string	Адрес резервной БД, для кластера указываются адреса через запятую	«»
   driver	Да	string	Путь до драйвера
   login	Нет	string	Логин БД	«»
   password	Нет	string	Пароль БД	«»
   save.skipped.tx.to.db	Нет	boolean	Признак сохранения ошибочных транзакций в теневую таблицу	true
   save.skipped.tx.to.kafka	Нет	boolean	Признак сохранения ошибочных транзакций в топик	false
   apply_position_schema	Нет	string	Схема для технических таблиц	«»
   origin_name	Нет	string	Префикс источника изменений для Active-Active	«»
   apply.thread.count	Нет	int	Число потоков для многопоточной репликации	1
   max.pool.size	Нет	int	Количество соединений к БД приемнику в пуле. Параметр многопоточной репликации	3
   transaction.size	Нет	int	Количество векторов изменений в транзакции. Параметр многопоточной репликации	500
   db.linger.ms	Нет	int	Количество миллисекунд на формирование пачки векторов изменений в транзакции. Параметр многопоточной репликации	1000
   idle.in.transaction.session.timeout	Нет	int	Время простоя транзакции до автоматического завершения сеанса (в миллисекундах). Необходимо чтобы освободить все блокировки сеанса и вновь задействовать слот подключения, очистить кортежи, видимые только для этой транзакции.	30000

4. Нажмите Сохранить.

Результат#

Соединение создано.