問(wèn)題描述

我正在研究 NIFI 數(shù)據(jù)流，其中我的用例是獲取 mysql 表數(shù)據(jù)并將其放入 hdfs/本地文件系統(tǒng).

我構(gòu)建了一個(gè)數(shù)據(jù)流管道，其中使用了 querydatabaseTable 處理器 ------ ConvertRecord --- putFile 處理器.

我的表架構(gòu) ---> id,name,city,Created_date

即使我在表中插入新記錄，我也能在目的地接收文件

但是，但是……

當(dāng)我更新現(xiàn)有行時(shí)，處理器沒(méi)有獲取這些記錄，看起來(lái)它有一些限制.

我的問(wèn)題是，如何處理這種情況?由任何其他處理器或需要更新某些屬性.

請(qǐng)人幫忙@Bryan Bende

QueryDatabaseTable Processor 需要被告知它可以使用哪些列來(lái)識(shí)別新數(shù)據(jù).

串行 id 或 created 時(shí)間戳是不夠的.

不要忘記將 Maximum-value Columns 設(shè)置為這些列.

所以我基本上要說(shuō)的是:

如果你自己不能判斷這是sql中的新記錄，nifi也不能.

I am working on NIFI Data Flow where my usecase is fetch mysql table data and put into hdfs/local file system.

I have built a data flow pipeline where i used querydatabaseTable processor ------ ConvertRecord --- putFile processor.

My Table Schema ---> id,name,city,Created_date

I am able to receive files in destination even when i am inserting new records in table

But, but ....

When i am updating exsiting rows then processor is not fetching those records looks like it has some limitation.

My Question is ,How to handle this scenario? either by any other processor or need to update some property.

PLease someone help @Bryan Bende

QueryDatabaseTable Processor needs to be informed which columns it can use to identify new data.

A serial id or created timestamp is not sufficient.

From the documentation:

Maximum-value Columns:

A comma-separated list of column names. The processor will keep track of the maximum value for each column that has been returned since the processor started running. Using multiple columns implies an order to the column list, and each column's values are expected to increase more slowly than the previous columns' values. Thus, using multiple columns implies a hierarchical structure of columns, which is usually used for partitioning tables. This processor can be used to retrieve only those rows that have been added/updated since the last retrieval. Note that some JDBC types such as bit/boolean are not conducive to maintaining maximum value, so columns of these types should not be listed in this property, and will result in error(s) during processing. If no columns are provided, all rows from the table will be considered, which could have a performance impact. NOTE: It is important to use consistent max-value column names for a given table for incremental fetch to work properly.

Judging be the table scheme, there is no sql-way of telling whether data was updated.

There are many ways to solve this. In your case, the easiest thing to do might be to rename column created to modified and set to now() on updates or to work with a second timestamp column.

So for instance

| stamp_updated | timestamp | CURRENT_TIMESTAMP   | on update CURRENT_TIMESTAMP |

is the new column added. In the processor you use the stamp_updated column to identify new data

Don't forget to set Maximum-value Columns to those columns.

So what I am basically saying is:

If you cannot tell that it is a new record in sql yourself, nifi cannot either.

這篇關(guān)于NIFI - QueryDatabaseTable 處理器.如何查詢被修改的行?的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，也希望大家多多支持html5模板網(wǎng)！