Skip to content

Instantly share code, notes, and snippets.

View raj454raj's full-sized avatar
🚀

Raj Patel raj454raj

🚀
160 followers · 4 following
View GitHub Profile
@raj454raj
raj454raj / http_client_comparison.rb
Created January 7, 2019 18:50
Show net/http module retries if the first one timed out over typhoeus
require 'net/http'
require 'uri'
require 'typhoeus'
def get_response(url, request_timeout)
# Raises exception on timeout
url = URI(url)
http = Net::HTTP.new(url.host, url.port)
request = Net::HTTP::Get.new url
http.read_timeout = request_timeout
@raj454raj
raj454raj / redis-slow-log-parse.rb
Created November 1, 2019 08:21
res = DEFAULT_REDIS_CLIENT.slowlog("GET", 128)
puts "Timestamp,Command,Time taken (in seconds)"
res.each do |one_list_item|
puts "\"#{Time.at(one_list_item[1])}\",\"#{one_list_item[3].join(' ')}\",#{one_list_item[2]*1.0/1000000}"
end
@raj454raj
raj454raj / redis-streams.md
Last active September 2, 2021 09:35
Redis streams cheatsheet
Commands Description
XADD mystream * message 1 Add to stream to insert {message: 1}
XLEN mystream Length of messages in mystream
XRANGE mystream - + COUNT 2 Return the first two elements
XREAD COUNT 2 STREAMS mystream 0 Read 2 elements in stream from the beginning
XREAD BLOCK 0 STREAMS mystream $ Wait indefinitely until a message
XREAD BLOCK 1000 STREAMS mystream $ Wait for 1 second for a message else timeout
XGROUP CREATE mystream group1 $ Create a group1 in consumer group in a stream
XREADGROUP GROUP group1 cons1 COUNT 1 STREAMS mystream > Consume new messages as cons1 in group1 and get all the new messages