AWS Data Firehose and Elasticsearch Integration

<pre><code class="language-toml">[[inputs.firehose]] ## Address and port to host HTTP listener on service_address = ":8080" ## Paths to listen to. # paths = ["/telegraf"] ## maximum duration before timing out read of the request # read_timeout = "5s" ## maximum duration before timing out write of the response # write_timeout = "5s" ## Set one or more allowed client CA certificate file names to ## enable mutually authenticated TLS connections # tls_allowed_cacerts = ["/etc/telegraf/clientca.pem"] ## Add service certificate and key # tls_cert = "/etc/telegraf/cert.pem" # tls_key = "/etc/telegraf/key.pem" ## Minimal TLS version accepted by the server # tls_min_version = "TLS12" ## Optional access key to accept for authentication. ## AWS Data Firehose uses "x-amz-firehose-access-key" header to set the access key. ## If no access_key is provided (default), authentication is completely disabled and ## this plugin will accept all request ignoring the provided access-key in the request! # access_key = "foobar" ## Optional setting to add parameters as tags ## If the http header "x-amz-firehose-common-attributes" is not present on the ## request, no corresponding tag will be added. The header value should be a ## json and should follow the schema as describe in the official documentation: ## https://docs.aws.amazon.com/firehose/latest/dev/httpdeliveryrequestresponse.html#requestformat # parameter_tags = ["env"] ## Data format to consume. ## Each data format has its own unique set of configuration options, read ## more about them here: ## https://github.com/influxdata/telegraf/blob/master/docs/DATA_FORMATS_INPUT.md # data_format = "influx" </code></pre>

<pre><code class="language-toml"> [[outputs.elasticsearch]] ## The full HTTP endpoint URL for your Elasticsearch instance ## Multiple urls can be specified as part of the same cluster, ## this means that only ONE of the urls will be written to each interval urls = [ "http://node1.es.example.com:9200" ] # required. ## Elasticsearch client timeout, defaults to "5s" if not set. timeout = "5s" ## Set to true to ask Elasticsearch a list of all cluster nodes, ## thus it is not necessary to list all nodes in the urls config option enable_sniffer = false ## Set to true to enable gzip compression enable_gzip = false ## Set the interval to check if the Elasticsearch nodes are available ## Setting to "0s" will disable the health check (not recommended in production) health_check_interval = "10s" ## Set the timeout for periodic health checks. # health_check_timeout = "1s" ## HTTP basic authentication details. ## HTTP basic authentication details # username = "telegraf" # password = "mypassword" ## HTTP bearer token authentication details # auth_bearer_token = "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9" ## Index Config ## The target index for metrics (Elasticsearch will create if it not exists). ## You can use the date specifiers below to create indexes per time frame. ## The metric timestamp will be used to decide the destination index name # %Y - year (2016) # %y - last two digits of year (00..99) # %m - month (01..12) # %d - day of month (e.g., 01) # %H - hour (00..23) # %V - week of the year (ISO week) (01..53) ## Additionally, you can specify a tag name using the notation {{tag_name}} ## which will be used as part of the index name. If the tag does not exist, ## the default tag value will be used. # index_name = "telegraf-{{host}}-%Y.%m.%d" # default_tag_value = "none" index_name = "telegraf-%Y.%m.%d" # required. ## Optional Index Config ## Set to true if Telegraf should use the "create" OpType while indexing # use_optype_create = false ## Optional TLS Config # tls_ca = "/etc/telegraf/ca.pem" # tls_cert = "/etc/telegraf/cert.pem" # tls_key = "/etc/telegraf/key.pem" ## Use TLS but skip chain &amp; host verification # insecure_skip_verify = false ## Template Config ## Set to true if you want telegraf to manage its index template. ## If enabled it will create a recommended index template for telegraf indexes manage_template = true ## The template name used for telegraf indexes template_name = "telegraf" ## Set to true if you want telegraf to overwrite an existing template overwrite_template = false ## If set to true a unique ID hash will be sent as sha256(concat(timestamp,measurement,series-hash)) string ## it will enable data resend and update metric points avoiding duplicated metrics with different id's force_document_id = false ## Specifies the handling of NaN and Inf values. ## This option can have the following values: ## none -- do not modify field-values (default); will produce an error if NaNs or infs are encountered ## drop -- drop fields containing NaNs or infs ## replace -- replace with the value in "float_replacement_value" (default: 0.0) ## NaNs and inf will be replaced with the given number, -inf with the negative of that number # float_handling = "none" # float_replacement_value = 0.0 ## Pipeline Config ## To use a ingest pipeline, set this to the name of the pipeline you want to use. # use_pipeline = "my_pipeline" ## Additionally, you can specify a tag name using the notation {{tag_name}} ## which will be used as part of the pipeline name. If the tag does not exist, ## the default pipeline will be used as the pipeline. If no default pipeline is set, ## no pipeline is used for the metric. # use_pipeline = "{{es_pipeline}}" # default_pipeline = "my_pipeline" # # Custom HTTP headers # To pass custom HTTP headers please define it in a given below section # [outputs.elasticsearch.headers] # "X-Custom-Header" = "custom-value" ## Template Index Settings ## Overrides the template settings.index section with any provided options. ## Defaults provided here in the config # template_index_settings = { # refresh_interval = "10s", # mapping.total_fields.limit = 5000, # auto_expand_replicas = "0-1", # codec = "best_compression" # } </code></pre>