Class: LogStash::Outputs::Stackify

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/stackify.rb

Overview

Use logstash to ship logs to Stackify

Instance Method Summary collapse

Instance Method Details

#multi_receive(events) ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
 
# File 'lib/logstash/outputs/stackify.rb', line 48

def multi_receive(events)

  begin

    default_level = 'info'
    default_servername = Socket.gethostname
    log_msg_groups = Hash.new

    events.each do |event|

      begin

        # message
        default_message = event.get('message')
        message = default_message
        unless @message_field.nil?
          message = event.get(@message_field.to_s)
          if message.nil? || message.empty?
            message = default_message
          end
        end

        # level
        level = default_level
        unless @level_field.nil?
          level = event.get(@level_field.to_s)
          if level.nil? || level.empty?
            level = default_level
          end
        end
        level = level.downcase

        # application name
        app_name = @default_app_name.to_s
        unless @app_name_field.nil?
          app_name = event.get(@app_name_field.to_s)
          if app_name.nil? || app_name.empty?
            app_name = @default_app_name.to_s
          end
        end

        # env name
        env_name = @default_env_name.to_s
        unless @env_name_field.nil?
          env_name = event.get(@env_name_field.to_s)
          if env_name.nil? || env_name.empty?
            env_name = @default_env_name.to_s
          end
        end

        # server name
        server_name = default_servername
        unless @server_name_field.nil?
          server_name = event.get(@server_name_field.to_s)
          if server_name.nil? || server_name.empty?
            server_name = default_servername
          end
        end

        # timestamp
        timestamp = nil
        begin
          timestamp = (event.get('@timestamp').to_f * 1000).to_i
        rescue StandardError => e
          $stdout.write('Error parsing @timestamp: ' + e.to_s)
        end
        if timestamp.nil?
            timestamp = DateTime.now.strftime('%Q')
        end

        # generate key
        log_msg_group_key = app_name + '|' + env_name + '|' + server_name

        # setup log msg group if needed
        unless log_msg_groups.key?(log_msg_group_key)
          log_msg_group = Hash.new
          log_msg_group['Env'] = env_name
          log_msg_group['ServerName'] = server_name
          log_msg_group['AppName'] = app_name
          log_msg_group['Logger'] = 'Logstash'
          log_msg_group['Platform'] = 'Logstash'
          log_msg_group['Msgs'] = Array.new
          log_msg_groups[log_msg_group_key] = log_msg_group
        end

        # generate log msg
        log_msg = Hash.new
        log_msg['Msg'] = message
        log_msg['EpochMs'] = timestamp
        log_msg['Level'] = level

        # add to log msg group
        log_msg_groups[log_msg_group_key]['Msgs'].push(log_msg)

      rescue StandardError => e
        $stdout.write(e.to_s)
      end

    end

    # post
    log_msg_groups.each do |key, log_msg_group|

      begin

        data = log_msg_group.to_json
        header = {
            'Content-Type' => 'application/json',
            'Accept' => 'appliation/json',
            'X-Stackify-PV' => 'V1',
            'X-Stackify-Key' => @key.to_s
        }

        uri = URI.parse('https://api.stackify.com/Log/Save')
        https = Net::HTTP.new(uri.host, uri.port)
        https.use_ssl = true
        req = Net::HTTP::Post.new(uri.path, initheader = header)
        req.body = data
        https.request(req)

      rescue StandardError => e
        $stdout.write(e.to_s)
      end

    end

  rescue StandardError => e
    $stdout.write(e.to_s)
  end

end

#register ⇒ Object 



41
42
 
# File 'lib/logstash/outputs/stackify.rb', line 41

def register
end