winebarrel

#!/usr/bin/env ruby
require 'aws-sdk'
require 'base64'

AWS.config(region: 'us-east-1')
client = AWS.kinesis.client
STREAM_NAME = 'hello'
SHARD_ID = 'shardId-000000000000'

# shard_idの取得

winebarrel

require 'json'
require 'openssl'
require 'net/http'
require 'net/https'
require 'time'
require 'stringio'
require 'zlib'

module Kinesis
  class Client

winebarrel

CREATE TABLE games (
  author STRING HASH,
  game_id NUMBER RANGE,
  INDEX game-type-id-index (game_type_id NUMBER) ALL,
  GLOBAL INDEX game-title-index (title STRING, version NUMBER) ALL
) read=4 write=4

winebarrel

--- /usr/lib/ruby/gems/1.8/gems/activerecord-3.2.15/lib/active_record/connection_adapters/abstract_mysql_adapter.rb.orig	2013-10-31 07:37:55.704402703 +0000
+++ /usr/lib/ruby/gems/1.8/gems/activerecord-3.2.15/lib/active_record/connection_adapters/abstract_mysql_adapter.rb.reconnect	2013-10-31 09:18:52.061099228 +0000
@@ -239,11 +239,16 @@

       # Executes the SQL statement in the context of this connection.
       def execute(sql, name = nil)
+        begin
         if name == :skip_logging
           @connection.query(sql)
         else