zoukankan      html  css  js  c++  java
  • Apache NiFi之MySQL数据同步到本地文件系统

    1).配置ExecuteSQLRecord

    a).选择ExecuteSQLRecord

    在Processor中搜索ExecuteSQLRecord

    b).配置ExecuteSQLRecord

    1.创建Database Connection Pool
    2.创建JsonRecordSetWriter
    3.配置SQL select query
    

      

    select Host,User,authentication_string from mysql.user;

    c).创建DBCPConnectionPool

    在Database Connection Pool中选择DBCPConnectionPool

    d).配置DBCPConnectionPool

    1.Database Connection URL: jdbc:mysql://hostname:3306/mysql
    2.Database Driver Class Name: com.mysql.jdbc.Driver
    3.Database User: username
    4.Database Password: password

    e).激活服务

    f).选择JsonRecordSetWriter

    在Processor中搜索JsonRecordSetWriter

    g).配置JsonRecordSetWriter

    h).选择AvroSchemaRegistry

    在Processor中搜索AvroSchemaRegistry

    i).配置AvroSchemaRegistry

    j).激活JsonRecordSetWriter & AvroSchemaRegistry

    2).配置PutFile

    a).选择PutFile

    在Processor中搜索PutFile

    b).配置PutFile

    1.配置Directory: 文件保存路径
    2.可配置Create Missing Directories: 默认true

    3).启动服务

    可以点击选择单个Processor启动,也可以在空白处点击流程启动

    4).验证结果

    a).MySQL源数据查询

    b).文件内容查询

  • 相关阅读:
    BZOJ-2431: [HAOI2009]逆序对数列 (傻逼递推)
    BZOJ3695 滑行
    BZOJ3689 异或之
    BZOJ3696 化合物
    BZOJ1393 [Ceoi2008]knights
    BZOJ2280 [Poi2011]Plot
    BZOJ1570 [JSOI2008]Blue Mary的旅行
    BZOJ2751 [HAOI2012]容易题(easy)
    BZOJ2818 Gcd
    BZOJ2426 [HAOI2010]工厂选址
  • 原文地址:https://www.cnblogs.com/felixzh/p/12124577.html
Copyright © 2011-2022 走看看