diff --git a/blackbox/logger/docker-compose.yml b/blackbox/logger/docker-compose.yml
new file mode 100644
index 00000000..2b0c57c0
--- /dev/null
+++ b/blackbox/logger/docker-compose.yml
@@ -0,0 +1,25 @@
+version: '2'
+services:
+  app:
+    image: golang:1.10
+    command: bash -c "go get ./... && go run main.go -port=5516 -dbhost=mysql -dbuser=root -dbpass=root"
+    ports:
+      - "5516:5516"
+    links:
+      - mysql
+    working_dir: /go/src/logger
+    volumes:
+      - gopath:/go
+      - .:/go/src/logger
+  mysql:
+    image: mysql:5.6.35
+    environment:
+      - "TZ=Asia/Tokyo"
+      - "MYSQL_ROOT_PASSWORD=root"
+    volumes:
+      - mysql:/var/lib/mysql
+      - ./sql:/docker-entrypoint-initdb.d
+
+volumes:
+  gopath:
+  mysql:
diff --git a/blackbox/logger/main.go b/blackbox/logger/main.go
new file mode 100644
index 00000000..f9243ca4
--- /dev/null
+++ b/blackbox/logger/main.go
@@ -0,0 +1,383 @@
+package main
+
+import (
+	"database/sql"
+	"encoding/json"
+	"flag"
+	"fmt"
+	"log"
+	"net/http"
+	"time"
+
+	_ "github.com/go-sql-driver/mysql"
+	"github.com/pkg/errors"
+)
+
+func main() {
+	var (
+		port   = flag.Int("port", 5516, "log app ranning port")
+		dbhost = flag.String("dbhost", "127.0.0.1", "database host")
+		dbport = flag.Int("dbport", 3306, "database port")
+		dbuser = flag.String("dbuser", "root", "database user")
+		dbpass = flag.String("dbpass", "", "database pass")
+		dbname = flag.String("dbname", "isulog", "database name")
+	)
+
+	flag.Parse()
+
+	addr := fmt.Sprintf(":%d", *port)
+	dbup := *dbuser
+	if *dbpass != "" {
+		dbup += ":" + *dbpass
+	}
+
+	dsn := fmt.Sprintf("%s@tcp(%s:%d)/%s?parseTime=true&loc=Local&charset=utf8mb4", dbup, *dbhost, *dbport, *dbname)
+	db, err := sql.Open("mysql", dsn)
+	if err != nil {
+		log.Fatalf("mysql connect failed. err: %s", err)
+	}
+	server := NewServer(db)
+
+	log.Printf("[INFO] start server %s", addr)
+	log.Fatal(http.ListenAndServe(addr, server))
+}
+
+func NewServer(db *sql.DB) *http.ServeMux {
+	server := http.NewServeMux()
+
+	h := &Handler{db}
+
+	server.HandleFunc("/send", h.Send)
+	server.HandleFunc("/send_bulk", h.SendBulk)
+
+	// default 404
+	server.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
+		log.Printf("[INFO] request not found %s", r.URL.RawPath)
+		Error(w, "Not found", 404)
+	})
+	return server
+}
+
+func Error(w http.ResponseWriter, err string, code int) {
+	http.Error(w, err, code)
+}
+
+func Success(w http.ResponseWriter) {
+	fmt.Fprintln(w, "ok")
+}
+
+const (
+	BulkSendLimit = 100
+	MySQLDatetime = "2006-01-02 15:04:05"
+	LocationName  = "Asia/Tokyo"
+)
+
+type TagType int
+
+const (
+	TagSignup TagType = 1 + iota
+	TagSignin
+	TagSellRequest
+	TagBuyRequest
+	TagBuyError
+	TagClose
+	TagSellClose
+	TagBuyClose
+)
+
+type Log struct {
+	Tag  string          `json:"tag"`
+	Time int64           `json:"time"`
+	Data json.RawMessage `json:"data"`
+}
+
+type BulkLog struct {
+	AppID string `json:"app_id"`
+	Logs  []Log  `json:"logs"`
+}
+
+type SoloLog struct {
+	Log
+	AppID string `json:"app_id"`
+}
+
+type Signup struct {
+	Name   string `json:"name"`
+	BankID string `json:"bank_id"`
+	UserID int64  `json:"user_id"`
+}
+
+type Signin struct {
+	UserID int64 `json:"user_id"`
+}
+
+type SellRequest struct {
+	UserID int64 `json:"user_id"`
+	SellID int64 `json:"sell_id"`
+	Amount int64 `json:"amount"`
+	Price  int64 `json:"price"`
+}
+
+type BuyRequest struct {
+	UserID int64 `json:"user_id"`
+	BuyID  int64 `json:"buy_id"`
+	Amount int64 `json:"amount"`
+	Price  int64 `json:"price"`
+}
+
+type BuyError struct {
+	UserID int64  `json:"user_id"`
+	Amount int64  `json:"amount"`
+	Price  int64  `json:"price"`
+	Error  string `json:"error"`
+}
+
+type Close struct {
+	TradeID int64 `json:"trade_id"`
+	Amount  int64 `json:"amount"`
+	Price   int64 `json:"price"`
+}
+
+type SellClose struct {
+	TradeID int64 `json:"trade_id"`
+	UserID  int64 `json:"user_id"`
+	SellID  int64 `json:"sell_id"`
+	Amount  int64 `json:"amount"`
+	Price   int64 `json:"price"`
+}
+
+type BuyClose struct {
+	TradeID int64 `json:"trade_id"`
+	UserID  int64 `json:"user_id"`
+	BuyID   int64 `json:"buy_id"`
+	Amount  int64 `json:"amount"`
+	Price   int64 `json:"price"`
+}
+
+type Handler struct {
+	db *sql.DB
+}
+
+func (s *Handler) Send(w http.ResponseWriter, r *http.Request) {
+	req := &SoloLog{}
+	if err := json.NewDecoder(r.Body).Decode(req); err != nil {
+		Error(w, "can't parse body", http.StatusBadRequest)
+		return
+	}
+	if req.AppID == "" {
+		Error(w, "app_id is required", http.StatusBadRequest)
+		return
+	}
+	err := s.putLog(req.Log, req.AppID)
+	switch err {
+	case nil:
+		Success(w)
+	default:
+		log.Printf("[WARN] %s", err)
+		Error(w, "internal server error", http.StatusInternalServerError)
+	}
+}
+
+func (s *Handler) SendBulk(w http.ResponseWriter, r *http.Request) {
+	req := &BulkLog{}
+	if err := json.NewDecoder(r.Body).Decode(req); err != nil {
+		Error(w, "can't parse body", http.StatusBadRequest)
+		return
+	}
+	if req.AppID == "" {
+		Error(w, "app_id is required", http.StatusBadRequest)
+		return
+	}
+	errors := make([]error, 0, len(req.Logs))
+	for _, l := range req.Logs {
+		err := s.putLog(l, req.AppID)
+		switch err {
+		case nil:
+		default:
+			log.Printf("[WARN] %s", err)
+			errors = append(errors, err)
+		}
+	}
+	if len(errors) > 0 {
+		Error(w, "internal server error", http.StatusInternalServerError)
+	} else {
+		Success(w)
+	}
+}
+
+func (s *Handler) putLog(l Log, appID string) error {
+	if len(l.Data) == 0 {
+		return errors.Errorf("%s data is required", l.Tag)
+	}
+	if l.Time < time.Now().Unix()-3600 {
+		return errors.Errorf("%d time is too old", l.Time)
+	}
+	lt := time.Unix(l.Time, 0)
+	var userID, tradeID int64
+	var tag TagType
+	// benchmarkerでどこまで見るかで各caseでinsertでも良い
+	switch l.Tag {
+	case "signup":
+		tag = TagSignup
+		data := &Signup{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrapf(err, "%s parse data failed", l.Tag)
+		}
+		if data.Name == "" {
+			return errors.Errorf("%s data.name is required", l.Tag)
+		}
+		if data.BankID == "" {
+			return errors.Errorf("%s data.bank_id is required", l.Tag)
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		userID = data.UserID
+	case "signin":
+		tag = TagSignin
+		data := &Signin{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrapf(err, "%s parse data failed", l.Tag)
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		userID = data.UserID
+	case "sell.request":
+		tag = TagSellRequest
+		data := &SellRequest{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		if data.SellID == 0 {
+			return errors.Errorf("%s data.sell_id is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		userID = data.UserID
+	case "buy.request":
+		tag = TagBuyRequest
+		data := &BuyRequest{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		if data.BuyID == 0 {
+			return errors.Errorf("%s data.buy_id is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		userID = data.UserID
+	case "buy.error":
+		tag = TagBuyError
+		data := &BuyError{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		if data.Error == "" {
+			return errors.Errorf("%s data.error is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		userID = data.UserID
+	case "close":
+		tag = TagClose
+		data := &Close{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.TradeID == 0 {
+			return errors.Errorf("%s data.trade_id is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		tradeID = data.TradeID
+	case "sell.close":
+		tag = TagSellClose
+		data := &SellClose{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.TradeID == 0 {
+			return errors.Errorf("%s data.trade_id is required", l.Tag)
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		if data.SellID == 0 {
+			return errors.Errorf("%s data.sell_id is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		tradeID = data.TradeID
+		userID = data.UserID
+	case "buy.close":
+		tag = TagBuyClose
+		data := &BuyClose{}
+		if err := json.Unmarshal(l.Data, data); err != nil {
+			return errors.Wrap(err, "parse data failed")
+		}
+		if data.TradeID == 0 {
+			return errors.Errorf("%s data.trade_id is required", l.Tag)
+		}
+		if data.UserID == 0 {
+			return errors.Errorf("%s data.user_id is required", l.Tag)
+		}
+		if data.BuyID == 0 {
+			return errors.Errorf("%s data.buy_id is required", l.Tag)
+		}
+		if data.Amount == 0 {
+			return errors.Errorf("%s data.amount is required", l.Tag)
+		}
+		if data.Price == 0 {
+			return errors.Errorf("%s data.price is required", l.Tag)
+		}
+		tradeID = data.TradeID
+		userID = data.UserID
+	default:
+		return errors.Errorf("%s unknown tag", l.Tag)
+	}
+
+	query := `INSERT INTO log (app_id, tag, time, user_id, trade_id, data) VALUES (?, ?, ?, ?, ?, ?)`
+	if _, err := s.db.Exec(query, appID, int(tag), lt.Format(MySQLDatetime), userID, tradeID, string(l.Data)); err != nil {
+		return errors.Wrap(err, "insert log failed")
+	}
+	return nil
+}
+
+func init() {
+	var err error
+	loc, err := time.LoadLocation(LocationName)
+	if err != nil {
+		log.Panicln(err)
+	}
+	time.Local = loc
+}
diff --git a/blackbox/logger/sql/00_create_database.sql b/blackbox/logger/sql/00_create_database.sql
new file mode 100644
index 00000000..ce9eadac
--- /dev/null
+++ b/blackbox/logger/sql/00_create_database.sql
@@ -0,0 +1 @@
+create database if not exists isulog default character set utf8mb4;
diff --git a/blackbox/logger/sql/isulog.sql b/blackbox/logger/sql/isulog.sql
new file mode 100644
index 00000000..5df228e0
--- /dev/null
+++ b/blackbox/logger/sql/isulog.sql
@@ -0,0 +1,14 @@
+use isulog;
+
+CREATE TABLE log (
+    id BIGINT NOT NULL AUTO_INCREMENT,
+    app_id VARBINARY(191) NOT NULL,
+    tag TINYINT NOT NULL,
+    time DATETIME NOT NULL,
+    user_id BIGINT NOT NULL,
+    trade_id BIGINT NOT NULL,
+    data TEXT NOT NULL,
+    PRIMARY KEY (id),
+    INDEX app_id_tag_user_id_idx (app_id, tag, user_id),
+    INDEX app_id_tag_trade_id_idx (app_id, tag, trade_id)
+) ENGINE=InnoDB DEFAULT CHARACTER SET utf8mb4;