out_nrlogs: wrap output in an array to match the API

While the current format will send the data successfully, New Relic interprets the whole payload as a stringified array. By sending as an array, we meet the New Relic MELT API spec, and are able to distinguish individual key/values from the payload. Sample spec can be seen here: https://docs.newrelic.com/docs/logs/new-relic-logs/log-api/introduction-log-api#log-attribute-examples Signed-off-by: Julian Giuca <[email protected]>
fluent · Jul 16, 2020 · 4f822aa · 4f822aa
1 parent b3604db
commit 4f822aa
Showing 1 changed file with 13 additions and 9 deletions.
diff --git a/plugins/out_nrlogs/newrelic.c b/plugins/out_nrlogs/newrelic.c
@@ -158,16 +158,17 @@ static flb_sds_t newrelic_compose_payload(struct flb_newrelic *ctx,
      * Following the New Relic Fluentd implementation, this is the
      * suggested structure for our payload:
      *
-     *     payload = {
-     *     'common' => {
-     *       'attributes' => {
-     *         'plugin' => {
-     *           'type' => 'fluentd',
-     *           'version' => NewrelicFluentdOutput::VERSION,
+     *     payload = {[
+     *       'common' => {
+     *         'attributes' => {
+     *           'plugin' => {
+     *             'type' => 'fluentd',
+     *             'version' => NewrelicFluentdOutput::VERSION,
+     *           }
      *         }
-     *       }
-     *     },
-     *     'logs' => []
+     *       },
+     *       'logs' => []
+     *     ]}
      */
 
     /* Count number of records */
@@ -178,6 +179,9 @@ static flb_sds_t newrelic_compose_payload(struct flb_newrelic *ctx,
     msgpack_sbuffer_init(&mp_sbuf);
     msgpack_packer_init(&mp_pck, &mp_sbuf, msgpack_sbuffer_write);
 
+    /* The New Relic MELT API format is wrapped in an array */
+    msgpack_pack_array(&mp_pck, 1);
+
     /* Map for 'common' and 'logs' */
     msgpack_pack_map(&mp_pck, 2);