如何协调 FINAL 数据库中的数据?

How to harmonize data inside FINAL database?

我正在测试 Quickstart UI 以熟悉 DHF。 以我的理解,默认配置有暂存数据库和最终数据库。 输入流将数据暂存,然后协调流将在最终数据库中创建协调数据。

现在,我的问题是如何应用额外的协调流程 协调数据已存在于最终数据库中?

我知道 writer 模块允许访问各种功能 针对最终数据库,实际上我可以代表查询控制台在这里做任何想做的事。 但是,我认为这不应该是正确的方法,甚至是成功的 通过数据协调过程(在数据库级别),我的跟踪记录充满了错误。 有什么建议或意见吗?

我个人更喜欢 运行 来自命令行的所有流程,因此我通常有一个 shell 脚本来触发输入并使用 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!