Subscribed unsubscribe Subscribe Subscribe

go-twitterstream

最近 go を書いてなかったのでリハビリがてら他のライブラリもあったような気がするけど twitter の stream につなぐやつを書いてみた

https://github.com/soh335/go-twitterstream

package main

import (
    "encoding/json"
    "github.com/soh335/go-twitterstream"
    "log"
)

func main() {
    client := &twitterstream.Client{
        ConsumerKey:     "...",
        ConsumerSecret:  "...",
        Token:           "...",
        TokenSecret:     "...",
        GzipCompression: true,
    }

    conn, err := client.Userstream("POST", map[string]string{"stringify_friend_ids": "true"})

    if err != nil {
        log.Fatal(err)
    }

    defer conn.Close()

    for {
        line, err := conn.Next()
        if err != nil {
            log.Fatal(err)
        }
        var item map[string]interface{}
        if err := json.Unmarshal(line, &item); err != nil {
            log.Fatal("json decode failed:" + err.Error())
        }
        log.Println(item)
    }
}

こんな感じで使う。