mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 22:57:16 -04:00
Basically works
This commit is contained in:
Martin Cleaver
parent
3af50f257b
commit
af52f5014c
1 changed files with 54 additions and 81 deletions
|
|
@ -1,32 +1,18 @@
|
|||
# Origin https://groups.google.com/forum/#!msg/logstash-users/exgrB4iQ-mw/R34apku5nXsJ
|
||||
# From https://gist.github.com/electrical/4660061e8fff11cdcf37#file-jira-rb
|
||||
# From https://botbot.me/freenode/logstash/msg/4169496/
|
||||
# and https://botbot.me/freenode/logstash/msg/4169496/
|
||||
# via https://gist.github.com/electrical/4660061e8fff11cdcf37#file-jira-rb
|
||||
# Settling on jiralicious as the bridge to JIRA
|
||||
|
||||
require "logstash/outputs/base"
|
||||
require "logstash/namespace"
|
||||
require "uri"
|
||||
# TODO(sissel): Move to something that performs better than net/http
|
||||
require "net/http"
|
||||
require "net/https"
|
||||
|
||||
# Ugly monkey patch to get around <http://jira.codehaus.org/browse/JRUBY-5529>
|
||||
Net::BufferedIO.class_eval do
|
||||
BUFSIZE = 1024 * 16
|
||||
|
||||
def rbuf_fill
|
||||
timeout(@read_timeout) {
|
||||
@rbuf << @io.sysread(BUFSIZE)
|
||||
}
|
||||
end
|
||||
end
|
||||
|
||||
require "jiralicious" # 0.2.2 works for me
|
||||
|
||||
#
|
||||
# This is most useful so you can use logstash to parse and structure
|
||||
# This is so is most useful so you can use logstash to parse and structure
|
||||
# your logs and ship structured, json events to JIRA
|
||||
#
|
||||
# To use this, you'll need to use a JIRA input with type 'http'
|
||||
# and 'json logging' enabled.
|
||||
# To use this, you'll need to ensure your JIRA instance allows REST calls
|
||||
|
||||
class LogStash::Outputs::Jira < LogStash::Outputs::Base
|
||||
config_name "jira"
|
||||
milestone 2
|
||||
|
|
@ -35,44 +21,44 @@ class LogStash::Outputs::Jira < LogStash::Outputs::Base
|
|||
# and has to have the REST interface enabled
|
||||
config :host, :validate => :string
|
||||
|
||||
# JIRA Project name
|
||||
config :project, :validate => :string, :required => true
|
||||
|
||||
# The RestAPI key
|
||||
# config :apikey, :validate => :string, :required => true
|
||||
|
||||
config :user, :validate => :string, :required => true
|
||||
config :username, :validate => :string, :required => true
|
||||
config :password, :validate => :string, :required => true
|
||||
|
||||
# Should the log action be sent over https instead of plain http
|
||||
config :proto, :validate => :string, :default => "http"
|
||||
# Javalicious has no proxy support
|
||||
###
|
||||
# JIRA Project number
|
||||
config :projectid, :validate => :string, :required => true
|
||||
|
||||
# Proxy Host
|
||||
config :proxy_host, :validate => :string
|
||||
# JIRA Issuetype number
|
||||
config :issuetypeid, :validate => :string, :required => true
|
||||
|
||||
# Proxy Port
|
||||
config :proxy_port, :validate => :number
|
||||
# JIRA Summary
|
||||
config :summary, :validate => :string, :required => true
|
||||
|
||||
# Proxy Username
|
||||
config :proxy_user, :validate => :string
|
||||
# JIRA Priority
|
||||
config :priority, :validate => :string, :required => true
|
||||
|
||||
# Proxy Password
|
||||
config :proxy_password, :validate => :password, :default => ""
|
||||
|
||||
# JIRA Reporter
|
||||
config :reporter, :validate => :string
|
||||
|
||||
# JIRA Reporter
|
||||
config :assignee, :validate => :string
|
||||
|
||||
### The following have not been implemented
|
||||
# Ticket creation method
|
||||
config :method, :validate => :string, :default => 'new'
|
||||
#config :method, :validate => :string, :default => 'new'
|
||||
|
||||
# Search fields; When in 'append' method. search for a ticket that has these fields and data.
|
||||
config :searchfields, :validate => :hash
|
||||
#config :searchfields, :validate => :hash
|
||||
|
||||
# createfields; Add data to these fields at initial creation
|
||||
config :createfields, :validate => :hash
|
||||
#config :createfields, :validate => :hash
|
||||
|
||||
# appendfields; Update data in these fields when appending data to an existing ticket
|
||||
config :appendfields, :validate => :hash
|
||||
#config :appendfields, :validate => :hash
|
||||
|
||||
# Comment; Add this in the comment field ( is for new and append method the same )
|
||||
config :comment, :validate => :string
|
||||
#config :comment, :validate => :string
|
||||
|
||||
|
||||
public
|
||||
|
|
@ -89,44 +75,31 @@ class LogStash::Outputs::Jira < LogStash::Outputs::Base
|
|||
return
|
||||
end
|
||||
|
||||
# Send the event over http.
|
||||
# curl -D- -u fred:fred -X POST --data {see below} -H "Content-Type: application/json" http://localhost:8090/rest/api/2/issue/
|
||||
# https://developer.atlassian.com/display/JIRADEV/JIRA+REST+API+Example+-+Create+Issue#JIRARESTAPIExample-CreateIssue-Request.3
|
||||
url = URI.parse("#{@proto}://#{@host}/rest/api/2/issue")
|
||||
@logger.info("JIRA Rest Url", :url => url)
|
||||
http = Net::HTTP::Proxy(@proxy_host, @proxy_port, @proxy_user, @proxy_password.value).new(url.host, url.port)
|
||||
if url.scheme == 'https'
|
||||
http.use_ssl = true
|
||||
http.verify_mode = OpenSSL::SSL::VERIFY_NONE
|
||||
Jiralicious.configure do |config|
|
||||
config.username = @username
|
||||
config.password = @password
|
||||
config.uri = @host
|
||||
config.auth_type = :cookie
|
||||
config.api_version = "latest"
|
||||
end
|
||||
#http://stackoverflow.com/questions/10919287/make-this-http-post-request-in-ruby
|
||||
request = Net::HTTP::Post.new(url.path)
|
||||
request.add_field('Content-Type', 'application/json')
|
||||
request.basic_auth @user, @password
|
||||
|
||||
request.body = '
|
||||
{
|
||||
"fields": {
|
||||
"project":
|
||||
{
|
||||
"key": "LOGSTASH"
|
||||
},
|
||||
"summary": "REST ye merry gentlemen.",
|
||||
"description": "Creating of an issue using project keys and issue type names using the REST API",
|
||||
"issuetype": {
|
||||
"name": "Bug"
|
||||
}
|
||||
}
|
||||
}'
|
||||
# "customfield_11050" : {"Value that we're putting into a Free Text Field."}
|
||||
# request.body = event.to_json
|
||||
# request.body = request.template
|
||||
@logger.info("request.body", :request_body => request.body)
|
||||
response = http.request(request)
|
||||
if response.is_a?(Net::HTTPSuccess)
|
||||
@logger.info("Event send to JIRA OK!")
|
||||
else
|
||||
@logger.warn("HTTP error", :error => response.error!)
|
||||
end
|
||||
|
||||
issue = Jiralicious::Issue.new
|
||||
issue.fields.set_id("project", @projectid) # would have prefered a project key, https://github.com/jstewart/jiralicious/issues/16
|
||||
issue.fields.set("summary", @summary)
|
||||
issue.fields.set_id("issuetype", @issuetypeid)
|
||||
issue.fields.set_name("reporter", @reporter)
|
||||
issue.fields.set_name("assignee", @assignee)
|
||||
issue.fields.set_id("priority", @priority)
|
||||
#puts issue.fields.to_yaml
|
||||
issue.save
|
||||
|
||||
|
||||
|
||||
# if response.is_a?(Net::HTTPSuccess)
|
||||
# @logger.info("Event send to JIRA OK!")
|
||||
# else
|
||||
# @logger.warn("HTTP error", :error => response.error!)
|
||||
# end
|
||||
end # def receive
|
||||
end # class LogStash::Outputs::Jira
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue