From 57fe80a6670da99565f789496ce2847800b1b8b6 Mon Sep 17 00:00:00 2001 From: w256 Date: Sun, 21 Feb 2016 06:11:46 +0900 Subject: [PATCH 1/2] adaption for json of out_mysql_replicator_elasticsearch.rb --- lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb index 91fd59e..527c70c 100644 --- a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb +++ b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb @@ -71,6 +71,11 @@ def write(chunk) end request.body = bulk_message.join("\n") + + request.body.gsub!(/\\"/, '"') + request.body.gsub!(/\"{/, '{') + request.body.gsub!(/}\"/, '}') + http.request(request).value end end From de9e8ebb063ad2f88b8a9985c70d6271459bc5fa Mon Sep 17 00:00:00 2001 From: w256 Date: Sun, 21 Feb 2016 06:18:03 +0900 Subject: [PATCH 2/2] adaption for json of out_mysql_replicator_elasticsearch.rb --- lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb index 527c70c..b388900 100644 --- a/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb +++ b/lib/fluent/plugin/out_mysql_replicator_elasticsearch.rb @@ -72,9 +72,9 @@ def write(chunk) request.body = bulk_message.join("\n") - request.body.gsub!(/\\"/, '"') - request.body.gsub!(/\"{/, '{') - request.body.gsub!(/}\"/, '}') + request.body.gsub!(/\\"/, '"') + request.body.gsub!(/\"{/, '{') + request.body.gsub!(/}\"/, '}') http.request(request).value end