组件示例

• 转换控制

  • 流程控制

    • FetchDistributedMapCache
    • GenerateFlowFile
    • RouteOnAttribute
    • Notify
    • Wait

  • 数据转换

    • AttributesToJSON
    • AggregateRecord
    • ConvertAvroToJSON
    • ConvertJSONToSQL
    • ConvertJSONToXML
    • ConvertXMLToJSON
    • EvaluateXQuery
    • EvaluateJsonPath
      • 键包含特殊字符
      • 值包含Tab真实值
    • ExecuteGroovyScript
    • ExtractText
    • ExtractJSONToAttributes
    • ExtractAvroToAttributes
    • ExtractXMLToAttributes
    • ExtractExcel
    • FetchDistributedMapCache
    • JoltTransformJSON
      • JSON替换值
      • JSON数据封装
    • MergeContent
    • MergeRecord
    • QueryRecord
    • ReplaceText
    • SplitJson
    • SplitRecord
    • UpdateAttribute
    • UpdateRecord

---

• 网络通信
  • ConsumePOP3
  • HandleHttpRequest
    • 单向安全认证
    • 客户端双向安全认证
    • 参数化访问路径
    • 初始化服务失败
    • 503错误
  • HandleHttpResponse
    • 响应失败
  • HandleSOAPHttpRequest
  • InvokeDubbo
  • InvokeHTTP
    • 支持安全认证
  • InvokeSOAP
    • 调用Web Service
    • 使用InvokeHTTP
  • PutEmail
  • SignatureProcessor
  • XXXLDAP
    • AddLDAP
    • CommonLDAPConnectionPool
    • CompareLDAP
    • DeleteLDAP
    • ModifyLDAP
    • ModifyDnLDAP
    • SearchLDAP
  • XXXMQTT
    • ConsumeMQTT
    • PublishMQTT

---

• 数据库
  • ConvertJSONToSQL
  • ExecuteStoreProcedure
  • ExecuteSQL
  • MongoDB
    • DeleteMongo
    • GetMongo
    • PutMongo
    • PutMongoRecord
    • RunMongoAggregation
  • PutDatabaseRecord
    • 字段转换问题
  • PutDruidRecord
  • PutHiveStreaming
    • Avro无效
    • HDFS权限
    • 配置文件不存在
  • PutKudu
  • QueryDatabaseTable

---

• 文件处理
  • 文件
    • PutFile

---

• 执行
  • ExecuteGroovyScript
  • ExecuteScript

---

• 数据处理

  • 数据输出

    • PutFile
    • HandleHttpRequest
      • 单向安全认证
      • 客户端双向安全认证
      • 参数化访问路径
      • 初始化服务失败
      • 503错误
    • HandleHttpResponse
      • 响应失败
    • PublishAMQP
    • PutEmail
    • PutHiveStreaming
      • Avro无效
      • HDFS权限
      • 配置文件不存在
    • XXXLDAP
      • AddLDAP
      • CommonLDAPConnectionPool
      • CompareLDAP
      • DeleteLDAP
      • ModifyLDAP
      • ModifyDnLDAP
      • SearchLDAP
    • XXXMQTT
      • ConsumeMQTT
      • PublishMQTT
    • Kafka
      • GetKafka
      • PutKafka

  • 数据抓取

    • ConsumePOP3
    • ExtractExcel
    • FetchDistributedMapCache
    • GenerateFlowFile
    • InvokeDubbo
    • Kafka
      • GetKafka
      • PutKafka
    • QueryDatabaseTable
    • QueryRecord
    • XXXMQTT
      • ConsumeMQTT
      • PublishMQTT

  • 消息事件

    • Kafka
      • GetKafka
      • PutKafka
    • PublishAMQP
    • XXXMQTT
      • ConsumeMQTT
      • PublishMQTT

---

• 大数据
  • PutHiveStreaming
    • Avro无效
    • HDFS权限
    • 配置文件不存在