我正在测试 Quickstart UI 以熟悉 DHF。据我了解,默认配置有暂存和最终数据库。输入流将数据放置在暂存中,然后协调流将在最终数据库中创建协调数据。
现在,我的问题是如何针对最终数据库中已经存在的协调数据应用额外的协调流程?
我知道编写器模块允许针对最终数据库访问各种功能,实际上我可以在这里代表查询控制台做任何想做的事情。但是,我认为这不应该是正确的方法,即使数据协调过程(在数据库级别)也很成功,我的跟踪记录充满了错误。有什么建议或意见吗?
我正在测试 Quickstart UI 以熟悉 DHF。据我了解,默认配置有暂存和最终数据库。输入流将数据放置在暂存中,然后协调流将在最终数据库中创建协调数据。
现在,我的问题是如何针对最终数据库中已经存在的协调数据应用额外的协调流程?
我知道编写器模块允许针对最终数据库访问各种功能,实际上我可以在这里代表查询控制台做任何想做的事情。但是,我认为这不应该是正确的方法,即使数据协调过程(在数据库级别)也很成功,我的跟踪记录充满了错误。有什么建议或意见吗?
就我个人而言,我更喜欢从命令行运行所有流程,因此我通常有一个 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
!