nifi mongo组件

### Apache NiFi MongoDB 组件使用指南

#### 1. 安装与配置
为了使Apache NiFi能够与MongoDB交互，需先确保已安装并正确配置了NiFi环境。对于HDF版本的NiFi安装可参照特定指导[^3]。

#### 2. 连接至MongoDB
通过`GetMongo`和`PutMongo`处理器实现从MongoDB读取数据或将数据写入MongoDB的功能。这些处理器依赖于MongoDB Java驱动程序来建立连接。设置时应提供必要的连接字符串和其他参数以指定目标数据库实例的位置以及认证详情。

# 示例：MongoDB连接属性
mongodb.uri=mongodb://localhost:27017/mydb?authSource=admin&readPreference=primaryPreferred&w=1

#### 3. 数据获取 (GetMongo)
此处理器用于查询MongoDB集合并将结果作为FlowFile输出。用户可以通过JSON格式定义查询条件，并利用正则表达式匹配文档字段值。此外还支持聚合管道操作以便执行复杂的分析任务。

// 查询示例
{
    "collection": "customers",
    "query": {"status": "active"},
    "projection": {"name": 1, "_id": 0}
}

#### 4. 数据存储 (PutMongo)
该处理器负责向MongoDB插入新记录或更新已有条目。输入通常来自上游节点传递过来的FlowFiles，其中包含待保存的内容。可通过设定替换模式决定是覆盖还是追加现有文档。

// 插入/更新命令模板
{
    "operation": "${mongo.operation}",
    "database": "test_db",
    "collection": "orders"
}

#### 5. 错误处理机制
针对可能出现的各种异常情况——比如网络中断、权限不足等问题，建议启用重试策略并捕获日志信息辅助排查原因。同时考虑采用事务性保障措施防止部分成功状态的发生。

---