Как согласовать данные в базе данных FINAL?

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

Теперь мой вопрос: как я могу применить дополнительный гармонизированный поток к гармонизированным данным, уже существующим в итоговой базе данных?

Я знаю, что модуль записи позволяет получить доступ ко всем видам функций для конечной базы данных, на самом деле я мог делать все, что хотел здесь, от имени консоли запросов. Тем не менее, я думаю, что это не должно быть правильным путем, даже если я успешно справился с процессом согласования данных (на уровне базы данных), мои записи трассировки были полны ошибок. Любой совет или комментарии?

Источник

1 ответ

Решение

Лично я предпочитаю запускать все потоки из командной строки, поэтому у меня обычно есть сценарий оболочки, который запускает ввод и гармонизирует потоки с помощью Gradle. Там вы можете легко указать системе гармонизации использовать FINAL в качестве входа и выхода. Например, вот так:

gradle hubRunFlow "-PenvironmentName=$env" \
  -PentityName=MyEntity \
  -PflowName=myentity-harmonize-flow \
  -PbatchSize=100 \
  -PthreadCount=16 \
  -PsourceDB=data-hub-FINAL \
  -PdestDB=data-hub-FINAL \
  -PshowOptions=true

НТН!

Источник
Другие вопросы по тегам