najeira

GoでKinesis用ライブラリを作るメモ

Writer

Kinesisにデータを送るクラス。

コネクションは呼び出し側で作成してもらう。 それを引数にしてWriterを生成する。

Addメソッドで行を追加していく。

najeira

package main

import (
	bigquery "code.google.com/p/google-api-go-client/bigquery/v2"
	"code.google.com/p/goauth2/oauth/jwt"
	"encoding/json"
	"fmt"
)

func main() {

najeira

# -*- coding: utf-8 -*-
import os
import datetime
import jinja2
import webapp2
from google.appengine.api import users
from google.appengine.ext import ndb

class Page(ndb.Model):
  title = ndb.StringProperty(indexed=False)

najeira

package main

import (
	"database/sql"
	"errors"
	"fmt"
	_ "github.com/go-sql-driver/mysql"
	"log"
)

najeira

GrowthForecast

How to setup GrowthForecast.

see: http://kazeburo.github.io/GrowthForecast/

yum

sudo yum update

najeira

def verify(message):
  # the string to sign
  sign_str = []
  for key in ("Message", "MessageId", "Subject", "Timestamp", "TopicArn", "Type"):
    if key == "Subject" and key not in message:
      continue
    sign_str.append(key)
    sign_str.append(message[key])
  sign_str.append("")
  sign_str = "¥n".join(sign_str)

najeira

http {
    include       /etc/nginx/mime.types;
    default_type  application/octet-stream;

    log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                      '$status $body_bytes_sent "$http_referer" '
                      '"$http_user_agent" "$request_time"';

    sendfile        on;
    keepalive_timeout  65;

najeira

from google.appengine.ext import db

class Foo(db.Model):
  pass

class Bar(db.Model):
  foo = db.ReferenceProperty(Foo)

Bar.foo.get_value_for_datastore(bar_obj) #=> Key of Foo

najeira

# -*- coding: utf-8 -*-

import datetime
from boto import rds

#設定
AccessKey = '****'
AccessSecret = '****'
DbinstanceId = '****'
Region = 'ap-northeast-1'

najeira

class QueryIterator(object):

  def __init__(self, query, limit=None):
    self.limit = limit
    self.count = 0
    if limit:
      config = datastore_query.QueryOptions(limit=limit, prefetch_size=limit)
    else:
      config = None
    self.iterator = query.run(config=config)