Как согласовать данные в базе данных FINAL? - PullRequest
0 голосов
/ 06 декабря 2018

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

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

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

1 Ответ

0 голосов
/ 06 декабря 2018

Лично я предпочитаю запускать все потоки из командной строки, поэтому у меня обычно есть сценарий оболочки, который запускает ввод и гармонизирует потоки, используя 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

HTH!

...