elasticsearch - 使用 NiFi 仅使用新的 ElasticSearch 文档
问题描述
我有一个用例，我必须使用 NiFi 定期获取特定索引的新记录（仅以前未获取的记录）并将其通过管道传输到其他存储执行一些 ETL。
我不确定如何处理仅获取新记录。有人处理过这样的用例吗？
解决方案
你能更具体地说明只获取新记录吗？当您说只有之前未提取的记录时，这是否意味着具有特定的时间线？哪些记录被称为新记录？有没有具体时间要求？
推荐阅读
- azure-cosmosdb - 具有多主配置的多个区域中的 CosmosDB 更改源
- c# - 在 Linq 中将 List 转换为 IQueryable 的问题
- python - 在一个图中绘制多个（2）seaborn联合图（重叠）
- webpack - Webpack 和 GLSL 着色器
- python - 停止 pytest 错误但不失败
- ruby-on-rails - Rails 5 按任务数量对用户进行排名
- jquery - jquery - 来自另一个函数的引用值
- javascript - 如何在 reactjs 中处理时间选择器选择
- java - Java MySQl - 过于频繁地打开和关闭连接？
- python - 如何在 keras CNN 中使用黑白图像？