PUT user   //索引名称
{
  "settings": {
    "number_of_replicas": 1,   //副本数量
    "number_of_shards": 5	//分片数量
  },
  "mappings": {	
    "item":{		//文档名称
      "properties":{		//properties下有很多属性 要求对应数据库属性
        "id":{		//属性名称
          "type":"integer"	//属性类型
        },
        "usercode":{
          "type":"text"
        },
        "username":{
          "type":"text",
          "analyzer":"ik_max_word"	//这是一个ik分词器
        },
        "gender":{
          "type":"integer"
        },
        "birthday":{
          "type":"date"
        },
        "phone":{
          "type":"text"
        },
        "address":{
          "type":"text",
          "analyzer": "ik_max_word"
        },
        "userrole":{
          "type":"text"
        }
      }
    }
  }
}

input {
  jdbc {
          # mysql jdbc connection string to our backup databse
          # the user we wish to excute our statement as
          jdbc_connection_string => "jdbc:mysql://ip地址:数据库端口号/数据库名称"
          jdbc_user => "数据库账号"
          jdbc_password => "数据库密码"
          # the path to our downloaded jdbc driver
          jdbc_driver_library => "数据库驱动jar文件的目录"
          # the name of the driver class for mysql
          jdbc_driver_class => "com.mysql.jdbc.Driver"
          jdbc_paging_enabled => "是否开启分页  默认true"
          jdbc_page_size => "每页显示多少条数据"
          #以下对应着要执行的sql的绝对路径。
          #statement_filepath => "sql文件的路径"
          statement => "SQL语句（原数据库查询的）"
          #定时字段 各字段含义（由左至右）分、时、天、月、年，全部为*默认含义为每分钟都更新（测试结果，不同的话请留>言指出）
      schedule => "* * * * *"
  }
}

output {
  elasticsearch {
          #ESIP地址与端口
          hosts => "http://要输入的ESIP地址:ES端口号"
          #ES索引名称（自己定义的）
          index => "ES索引"
          #自增ID编号
          document_id => "%{id}"
          document_type => "item"
  }
  stdout {
      #以JSON格式输出
      codec => json_lines
  }
}