End of Support
Important: The fluent-plugin-splunk-hec will reach End of Support on January 1, 2024. After that date, this repository will no longer receive updates from Splunk and will no longer be supported by Splunk. Until then, only critical security fixes and bug fixes will be provided.
fluent-plugin-splunk-hec
Fluentd output plugin to send events and metrics to Splunk in 2 modes:
- Via Splunk's HEC (HTTP Event Collector) API
- Via the Splunk Cloud Services (SCS) Ingest API
Installation
RubyGems
$ gem install fluent-plugin-splunk-hec
Bundler
Add following line to your Gemfile:
gem "fluent-plugin-splunk-hec"
And then execute:
$ bundle
Configuration
- See also: Output Plugin Overview
Example 1: Minimum HEC Configuration
<match **>
@type splunk_hec
hec_host 12.34.56.78
hec_port 8088
hec_token 00000000-0000-0000-0000-000000000000
</match>
This example is very basic, it just tells the plugin to send events to Splunk HEC on https://12.34.56.78:8088
(https is the default protocol), using the HEC token 00000000-0000-0000-0000-000000000000
. It will use whatever index, source, sourcetype are configured in HEC. And the host
of each event is the hostname of the machine which running fluentd.
Example 2: SCS Ingest Configuration example
<match **>
@type splunk_ingest_api
service_client_identifier xxxxxxxx
service_client_secret_key xxxx-xxxxx
token_endpoint /token
ingest_auth_host auth.scp.splunk.com
ingest_api_host api.scp.splunk.com
ingest_api_tenant <mytenant>
ingest_api_events_endpoint /<mytenant>/ingest/v1beta2/events
debug_http false
</match>
This example shows the configuration to be used for sending events to ingest API. This configuration shows how to use service_client_identifier
, service_client_secret_key
to get token from token_endpoint
and send events to ingest_api_host
for the tenant ingest_api_tenant
at the endpoint ingest_api_events_endpoint
. The debug_http
flag indicates whether the user wants to print debug logs to stdout.
Example 3: Overwrite HEC defaults
<match **>
@type splunk_hec
hec_host 12.34.56.78
hec_port 8088
hec_token 00000000-0000-0000-0000-000000000000
index awesome
source ${tag}
sourcetype _json
</match>
This configuration will
- send all events to the
awesome
index, and - set their source to the event tags.
${tag}
is a special value which will be replaced by the event tags, and - set their sourcetype to
_json
.
Sometimes you want to use the values from the input event for these parameters, this is where the *_key
parameters help.
<match **>
...omitting other parameters...
source_key file_path
</match>
In this example (in order to keep it concise, we just omitted the repeating parameters, and we will keep doing so in the following examples), it uses the source_key
config to set the source of event to the value of the event's file_path
field. Given an input event like
{"file_path": "/var/log/splunk.log", "message": "This is an exmaple.", "level": "info"}
Then the source for this event will be "/var/log/splunk.log". And the "file_path" field will be removed from the input event, so what you will eventually get ingested in Splunk is:
{"message": "This is an example.", "level": "info"}
If you want to keep "file_path" in the event, you can use keep_keys
.
Besides source_key
there are also other *_key
parameters, check the parameters details below.
Example 4: Sending metrics
Metrics is available since Splunk 7.0.0, you can use this output plugin to send events as metrics to a Splunk metric index by setting data_type
to "metric".
<match **>
@type splunk_hec
data_type metric
hec_host 12.34.56.78
hec_port 8088
hec_token 00000000-0000-0000-0000-000000000000
</match>
With this configuration, the plugin will treat each input event as a collection of metrics, i.e. each key-value pair in the event is a metric name-value pair. For example, given an input event like
{"cpu/usage": 0.5, "cpu/rate": 10, "memory/usage": 100, "memory/rss": 90}
then 4 metrics will be sent to splunk.
If the input events are not like this, instead they have the metric name and metric value as properties of the event. Then you can use metric_name_key
and metric_value_key
. Given an input event like
{"metric": "cpu/usage", "value": 0.5, "app": "web_ui"}
You should change the configuration to
<match **>
@type splunk_hec
data_type metric
hec_host 12.34.56.78
hec_port 8088
hec_token 00000000-0000-0000-0000-000000000000
metric_name_key metric
metric_value_key value
</match>
All other properties of the input (in this example, "app"), will be sent as dimensions of the metric. You can use the <fields>
section to customize the dimensions.
Type of plugin
@type
This value must be set to splunk_hec
when using HEC API and to splunk_ingest_api
when using the ingest API. Only one type either splunk_hec
or splunk_ingest_api
is expected to be used when configuring this plugin.
Parameters for splunk_hec
protocol (enum) (optional)
This is the protocol to use for calling the HEC API. Available values are: http, https. This parameter is
set to https
by default.
hec_host (string) (required)
The hostname/IP for the HEC token or the HEC load balancer.
hec_port (integer) (optional)
The port number for the HEC token or the HEC load balancer. The default value is 8088
.
hec_token (string) (required)
Identifier for the HEC token.
hec_endpoint (string) (optional)
The HEC REST API endpoint to use. The default value is services/collector
.
metrics_from_event (bool) (optional)
When data_type
is set to "metric", the ingest API will treat every key-value pair in the input event as a metric name-value pair. Set metrics_from_event
to false
to disable this behavior and use metric_name_key
and metric_value_key
to define metrics. The default value is true
.
metric_name_key (string) (optional)
Field name that contains the metric name. This parameter only works in conjunction with the metrics_from_event
paramter. When this prameter is set, the metrics_from_event
parameter is automatically set to false
.
metric_value_key (string) (optional)
Field name that contains the metric value, this parameter is required when metric_name_key
is configured.
coerce_to_utf8 (bool) (optional)
Indicates whether to allow non-UTF-8 characters in user logs. If set to true
, any non-UTF-8 character is replaced by the string specified in non_utf8_replacement_string
. If set to false
, the Ingest API errors out any non-UTF-8 characters. This parameter is set to true
by default.
non_utf8_replacement_string (string) (optional)
If coerce_to_utf8
is set to true
, any non-UTF-8 character is replaced by the string you specify in this parameter. The parameter is set to ' '
by default.
Parameters for splunk_ingest_api
service_client_identifier: (optional) (string)
Splunk uses the client identifier to make authorized requests to the ingest API.
service_client_secret_key: (string)
The client identifier uses this authorization to make requests to the ingest API.
token_endpoint: (string)
This value indicates which endpoint Splunk should look to for the authorization token necessary for requests to the ingest API.
ingest_api_host: (string)
Indicates which url/hostname to use for requests to the ingest API.
ingest_api_tenant: (string)
Indicates which tenant Splunk should use for requests to the ingest API.
ingest_api_events_endpoint: (string)
Indicates which endpoint to use for requests to the ingest API.
debug_http: (bool)
Set to True if you want to debug requests and responses to ingest API. Default is false.
Parameters for both splunk_hec
and splunk_ingest_api
index (string) (optional)
Identifier for the Splunk index to be used for indexing events. If this parameter is not set,
the indexer is chosen by HEC. Cannot set both index
and index_key
parameters at the same time.
index_key (string) (optional)
The field name that contains the Splunk index name. Cannot set both index
and index_key
parameters at the same time.
host (string) (optional)
The host location for events. Cannot set both host
and host_key
parameters at the same time.
If the parameter is not set, the default value is the hostname of the machine runnning fluentd.
host_key (string) (optional)
Key for the host location. Cannot set both host
and host_key
parameters at the same time.
source (string) (optional)
The source field for events. If this parameter is not set, the source will be decided by HEC.
Cannot set both source
and source_key
parameters at the same time.
source_key (string) (optional)
Field name to contain source. Cannot set both source
and source_key
parameters at the same time.
sourcetype (string) (optional)
The sourcetype field for events. When not set, the sourcetype is decided by HEC.
Cannot set both source
and source_key
parameters at the same time.
sourcetype_key (string) (optional)
Field name that contains the sourcetype. Cannot set both source
and source_key
parameters at the same time.
time_key (string) (optional)
Field name to contain Splunk event time. By default will use fluentd'd time.
fields (init) (optional)
Lets you specify the index-time fields for the event data type, or metric dimensions for the metric data type. Null value fields are removed.
keep_keys (boolean) (Optional)
By default, all the fields used by the *_key
parameters are removed from the original input events. To change this behavior, set this parameter to true
. This parameter is set to false
by default.
When set to true, all fields defined in index_key
, host_key
, source_key
, sourcetype_key
, metric_name_key
, and metric_value_key
are saved in the original event.
<fields> section (optional) (single)
Depending on the value of data_type
parameter, the parameters inside the <fields>
section have different meanings. Despite the meaning, the syntax for parameters is unique.
app_name (string) (Optional)
Splunk app name using this plugin (default to hec_plugin_gem
)
app_version (string) (Optional)
The version of Splunk app using this this plugin (default to plugin version)
custom_headers (Hash) (Optional)
Hash of custom headers to be added to the HTTP request. Used to populate override_headers
attribute of the underlying Net::HTTP::Persistent
connection.
When data_type
is event
In this case, parameters inside <fields>
are used as indexed fields and removed from the original input events. Please see the "Add a "fields" property at the top JSON level" here for details. Given we have configuration like
<match **>
@type splunk_hec
...omitting other parameters...
<fields>
file
level
app application
</fields>
</match>
and an input event like
{"application": "webServer", "file": "server.rb", "lineNo": 100, "level": "info", "message": "Request finished in 30ms."}
Then the HEC request JSON payload will be:
{
// omitting other fields
// ...
"event": "{\"lineNo\": 100, \"message\": \"Request finished in 30ms.\"}",
"fields": {
"file": "server.rb",
"level": "info",
"app": "webServer"
}
}
As you can see, parameters inside <fields>
section can be a key-value pair or just a key (a name).
If a parameter is a key-value, the key will be the name of the field inside the "fields"
JSON object,
whereas the value is the field name of the input event. So a key-value pair is a rename.
If a parameter has just a key, it means its value is exactly the same as the key.
When data_type
is metric
For metrics, parameters inside <fields>
are used as dimensions. If <fields>
is not presented, the original input event will be used as dimensions. If an empty <fields></fields>
is presented, no dimension is sent. For example, given the following configuration:
<match **>
@type splunk_hec
data_type metric
...omitting other parameters...
metric_name_key name
metric_value_key value
<fields>
file
level
app application
</fields>
</match>
and the following input event:
{"application": "webServer", "file": "server.rb", "value": 100, "status": "OK", "message": "Normal", "name": "CPU Usage"}
Then, a metric of "CPU Usage" with value=100, along with 3 dimensions file="server.rb", status="OK", and app="webServer" are sent to Splunk.
<format> section (optional) (multiple)
The <format>
section let you define which formatter to use to format events.
By default, it uses the json
formatter.
Besides the @type
parameter, you should define the other parameters for the formatter inside this section.
Multiple <format>
sections can be defined to use different formatters for different tags. Each <format>
section accepts an argument just like the <match>
section does to define tag matching. By default, every event is formatted with json
. For example:
<match **>
@type splunk_hec
...
<format sometag.**>
@type single_value
message_key log
</format>
<format some.othertag>
@type csv
fields ["some", "fields"]
</format>
This example:
- Formats events with tags that start with
sometag.
with thesingle_value
formatter - Formats events with tags
some.othertag
with thecsv
formatter - Formats all other events with the
json
formatter (the default formatter)
If you want to use a different default formatter, you can add a <format **>
(or <format>
) section.
@type (string) (required)
Specifies which formatter to use.
Net::HTTP::Persistent parameters (optional)
The following parameters can be used for tuning HTTP connections:
gzip_compression (boolean)
Whether to use gzip compression on outbound posts. This parameter is set to false
by default for backwards compatibility.
idle_timeout (integer)
The default is five seconds. If a connection has not been used for five seconds, it is automatically reset at next use, in order to avoid attempting to send to a closed connection. Specifiy nil
to prohibit any timeouts.
read_timeout (integer)
The amount of time allowed between reading two chunks from the socket. The default value is nil
, which means no timeout.
open_timeout (integer)
The amount of time to wait for a connection to be opened. The default is nil
, which means no timeout.
SSL parameters
The following optional parameters let you configure SSL for HTTPS protocol.
client_cert (string)
The path to a file containing a PEM-format CA certificate for this client.
client_key (string)
The private key for this client.
ca_file (string)
The path to a file containing CA cerificates in PEM format. The plugin will verify the TLS server certificate presented by Splunk against the certificates in this file, unless verification is disabled by the ssl_insecure
option.
ca_path (string)
The path to a directory containing CA certificates in PEM format. The plugin will verify the TLS server certificate presented by Splunk against the certificates in this file, unless verification is disabled by the ssl_insecure
option.
ciphers (array)
List of SSl ciphers allowed.
insecure_ssl (bool)
Specifies whether an insecure SSL connection is allowed. If set to false
(the default), the plugin will verify the TLS server certificate presented by Splunk against the CA certificates provided by the ca_file
/ca_path
options, and reject the certificate if if verification fails.
require_ssl_min_version (bool)
When set to true
(the default), the plugin will require TLSv1.1 or later for its connection to Splunk.
consume_chunk_on_4xx_errors (bool)
Specifies whether any 4xx HTTP response status code consumes the buffer chunks. If set to false
, Splunk will fail to flush the buffer on such status codes. This parameter is set to true
by default for backwards compatibility.
About Buffer
This plugin sends events to HEC using batch mode.
It batches all events in a chunk in one request. So you need to configure the <buffer>
section carefully to gain the best performance.
Here are some hints:
- Read through the fluentd buffer document to understand the buffer configurations.
- Use
chunk_limit_size
and/orchunk_limit_records
to define how big a chunk can be. And remember that all events in a chunk will be sent in one request. - Splunk has a limit on how big the payload of a HEC request can be. And it's defined with
max_content_length
in the[http_input]
section oflimits.conf
. In Splunk of version 6.5.0+, the default value is 800MiB, while in versions before 6.5.0, it's just 1MB. Make sure your chunk size won't exceed this limit, or you should change the limit on your Splunk deployment. - Sending requests to HEC takes time, so if you flush your fluentd buffer too fast (for example, with a very small
flush_interval
), it's possible that the plugin cannot catch up with the buffer flushing. There are two ways you can handle this situation, one is to increase theflush_interval
or use multiple flush threads by settingflush_thread_count
to a number bigger than 1.
License
Please see LICENSE.