Wicked stuff
https://video.fosdem.org/2018/H.1302%20(Depage)/jiting_postgresql_using_llvm.mp4
import xml.etree.ElementTree as ET | |
import iso8601 | |
tree = ET.parse('310TKQ2-log.xml') | |
root = tree.getroot() | |
for child in root: | |
timestamp = iso8601.parse_date(child.attrib["Timestamp"]) | |
print("%s %s %s %s" % (timestamp, child.attrib["AgentID"], child.attrib["Severity"], child[0].text)) |
#!/usr/bin/python -u | |
import os | |
import sys | |
from datetime import datetime | |
import urllib2 | |
import time | |
def get_gh_ratelimits(token): |
def load_our_config(all=false) | |
files = Dir['conf.d/*.conf'] | |
@@configuration = String.new | |
files.sort.each do |file| | |
if all | |
@@configuration << File.read(file) | |
elsif file !~ /output/ and file !~ /input/ | |
@@configuration << File.read(file) | |
end | |
end |
# encoding: utf-8 | |
require "logstash/devutils/rspec/spec_helper" | |
describe "filebeat-forwarded plain text log" do | |
files = Dir['conf.d/*.conf'] | |
@@configuration = String.new | |
files.sort.each do |file| | |
@@configuration << File.read(file) | |
end |
# envoy default log format: | |
# https://www.envoyproxy.io/docs/envoy/latest/configuration/access_log#config-access-log-default-format | |
# | |
# [%START_TIME%] "%REQ(:METHOD)% %REQ(X-ENVOY-ORIGINAL-PATH?:PATH)% %PROTOCOL%" | |
# %RESPONSE_CODE% %RESPONSE_FLAGS% %BYTES_RECEIVED% %BYTES_SENT% %DURATION% | |
# %RESP(X-ENVOY-UPSTREAM-SERVICE-TIME)% "%REQ(X-FORWARDED-FOR)%" "%REQ(USER-AGENT)%" | |
# "%REQ(X-REQUEST-ID)%" "%REQ(:AUTHORITY)%" "%UPSTREAM_HOST%" | |
# | |
ENVOY \[%{TIMESTAMP_ISO8601:timestamp}\] "%{DATA:method} %{DATA:original_path} %{DATA:protocol}" %{DATA:response_code} %{DATA:response_flags} %{NUMBER:bytes_rcvd} %{NUMBER:bytes_sent} %{NUMBER:duration} %{DATA:upstream_svc_time} "%{DATA:x-forwarded-for}" "%{DATA:useragent}" "%{DATA:request_id}" "%{DATA:authority}" "%{DATA:upstream_host}" |
public BulkScorer bulkScorer(LeafReaderContext context) throws IOException { | |
final float score = score(); | |
final int maxDoc = context.reader().maxDoc(); | |
return new BulkScorer() { | |
@Override | |
public int score(LeafCollector collector, Bits acceptDocs, int min, int max) throws IOException { | |
max = Math.min(max, maxDoc); | |
FakeScorer scorer = new FakeScorer(); | |
scorer.score = score; | |
collector.setScorer(scorer); |
# encoding: utf-8 | |
require "logstash/devutils/rspec/spec_helper" | |
files = Dir['conf.d/*.conf'] | |
@@configuration = String.new | |
files.sort.each do |file| | |
@@configuration << File.read(file) | |
end | |
describe "simple test" do |
provisioner: | |
omnibus_cachier: true | |
name: salt_solo | |
formula: service | |
state_top: | |
base: | |
"*": | |
- service |
import salt.exceptions | |
import logging | |
import time | |
__name__ = 'ratelimit' | |
log = logging.getLogger(__name__) | |
def event(name, event_in, event_out): | |
bucket = {} |