nfo

# Monkey patch Facebooker to set an access token instead of a session key,
# and use the access token on EVERY requests.
Facebooker::Session.class_eval do
  def post_without_logging_with_access_token(method, params = {}, use_session_key = true, &proc)
    params[:access_token] ||= (params.delete(:session_key) || @session_key)
    post_without_logging_without_access_token(method, params, false, &proc)
  end
  alias_method_chain :post_without_logging, :access_token
end

nfo

# The Riak object "b1/a" is linked to objects in "b2".
# The objects in "b2" contain a JSON hash with a "links" key. This list contains an array of ids.
# The objects "b3/idX" are the final objects, we can process them in maps and a reduce.

results = Riak::MapReduce.new(client).
            add('b1', 'a').
            # link-walk to objects in 'b2'
            link({:bucket => 'b2', :tag => '_', :keep => false}).
            # return a array of tuples [bucket, id], that Riak will recognize and follow
            map("function(v, keydata, arg) { return v.not_found ? [] : JSON.parse(v.values[0].data).links.map(function(x) { return [arg, x]; }); }", :keep => false, :arg => 'b3').

nfo

# Following http://gist.github.com/472547
# If links are already in the 'b2' objects, then getting the top 5 can be done in the first map function

results = Riak::MapReduce.new(client).
            add('b1', 'a').
            link({:bucket => 'b2', :tag => '_', :keep => false}).
            # This first map only emits 5 items instead of all of them
            map("function(v, keydata, arg) { return v.not_found ? [] : JSON.parse(v.values[0].data).links.map(function(x) { return [arg, x]; }).slice(0, 5); }", :keep => false, :arg => 'b3').
            # The following map did not get the 5 items in the correct order ...
            map("function(v) { item = JSON.parse(v.values[0].data); return [item]; }", :keep => false).

nfo

Riak::Client::CurbBackend.class_eval do
  private
  def perform_with_logs(method, uri, headers, expect, data=nil)
    puts "\e[31m#{method.upcase} #{uri}\e[0m"
    puts "\t\e[33m#{headers}\e[0m"
    # puts "\t\e[36m#{expect}\e[0m"
    puts "\t\e[34m#{data}\e[0m" if data
    # puts "\t\e[37m#{caller.last}\e[0m"
    puts
    perform_without_logs(method, uri, headers, expect, data)

nfo

require 'rubygems'
require 'sinatra'

get '/' do
  Dir.mktmpdir('screenme') do |dir|
    file = File.join(dir, Time.now.strftime('%Y%m%d%H%M%S') + '.png')
    %x(/usr/sbin/screencapture -x #{file})
    send_file file
  end
end

nfo

[user@server yum.repos.d]# yum install maven2
Loaded plugins: fastestmirror, presto
Loading mirror speeds from cached hostfile
 * base: centos.crazyfrogs.org
 * epel: mirror.bytemark.co.uk
 * extras: centos.crazyfrogs.org
 * jpackage-generic: jpackage.netmindz.net
 * jpackage-generic-updates: jpackage.netmindz.net
 * rpmforge: apt.sw.be
 * rpmforge-extras: apt.sw.be

nfo

Aws Usage

Download AWS usage reports, in XML, CSV or parsed CSV. Based on the Python gist A script to query the Amazon Web Services (S3/EC2/etc) usage reports programmatically..

require 'aws_usage'

# Yield rows from report
aws_usage = AwsUsage.new('my@email.com', 'mypassword')

nfo

The code below could be invalid, it's being discussed on the Kafka mailing list here: http://mail-archives.apache.org/mod_mbox/kafka-users/201701.mbox/%3cCABQKjkKMwQJKzzvJbFS6jHigmQgJ675aMhsqiRptmasf4kZF4A@mail.gmail.com%3e

nfo

Custom serde for windowed records. Why ? http://mail-archives.apache.org/mod_mbox/kafka-users/201701.mbox/%3cCABQKjk+NtexSyt3gB0hA8w0kYqSkwxWkVUpvSXH9h8uJD_SLZA@mail.gmail.com%3e.

nfo

/**
 * Handle records with a timestamp in their Avro value.
 * Expects a LONG field named "timestamp".
 * Any problem makes this extractor return the record's internal timestamp.
 */
public class InValueTimestampExtractor implements TimestampExtractor {

  @Override
  public long extract(ConsumerRecord<Object, Object> record) {
    if (record != null && record.value() != null) {