Merge pull request #10 from smira/fix-exceptions

Fix incorrect statement split, use more relaxed JSON encoder
yokawasa · Jul 31, 2019 · f61cb7e · f61cb7e
2 parents 43b4b7a + ab482e8
commit f61cb7e
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/fluent-plugin-azure-loganalytics.gemspec b/fluent-plugin-azure-loganalytics.gemspec
@@ -20,6 +20,7 @@ Gem::Specification.new do |gem|
 
   gem.add_dependency "fluentd", [">= 0.14.15", "< 2"]
   gem.add_dependency "rest-client"
+  gem.add_dependency "yajl-ruby"
   gem.add_dependency "azure-loganalytics-datacollector-api", [">= 0.1.5"]
   gem.add_development_dependency "bundler", "~> 1.11"
   gem.add_development_dependency "rake", "~> 10.0"

diff --git a/lib/fluent/plugin/out_azure-loganalytics.rb b/lib/fluent/plugin/out_azure-loganalytics.rb
@@ -95,12 +95,12 @@ def write(chunk)
       begin
         res = @client.post_data(@log_type, records, @time_generated_field)
         if not Azure::Loganalytics::Datacollectorapi::Client.is_success(res)
-          log.fatal "DataCollector API request failure: error code: "
-                  + "#{res.code}, data=>" + records.to_json
+          log.fatal "DataCollector API request failure: error code: " +
+                  "#{res.code}, data=>" + Yajl.dump(records)
         end
       rescue Exception => ex
-        log.fatal "Exception occured in posting to DataCollector API: "
-                  + "'#{ex}', data=>" + records.to_json
+        log.fatal "Exception occured in posting to DataCollector API: " +
+                  "'#{ex}', data=>" + Yajl.dump(records)
       end
     end
   end