mk-mode BLOG

このブログは自作の自宅サーバに構築した Debian GNU/Linux で運用しています。
PC・サーバ構築等の話題を中心に公開しております。(クローンサイト: GitHub Pages

ブログ開設日2009-01-05
サーバ連続稼働時間
Reading...
Page View 合計
Reading...
今日
Reading...
昨日
Reading...

C++ - Twitter Streaming API でツイート取得!

[ プログラミング ] [ C言語, Twitter ]

こんばんは。

C++ で Twitter Streming API を使用してツイート等の情報を取得する方法についての記録(ソースコードの紹介)です。

(C++ にそれほど精通している訳でもありません。ご承知おきください)

0. 前提条件

  • Linux Mint 17 (64bit) での作業を想定。
  • g++(GCC) 4.9.1 での作業を想定。
  • libcurl4-dev (= libcurl4-openssl-dev or libcurl4-nss-dev or libcurl4-gnutls-dev) がインストール済みであること。
  • liboauth-dev がインストール済みであること。

1. C++ ソースコード作成

以下のような C++ ソースコードを作成。
(Public Streams / sample の情報を取得する例)

TwitterStream.cpp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
/*
 * Getting timelines by Twitter Streaming API
 */
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <oauth.h>
#include <curl/curl.h>
#include <sstream>

using namespace std;

size_t fncCallback(char* ptr, size_t size, size_t nmemb, string* stream) {
    int iRealSize = size * nmemb;
    stream->append(ptr, iRealSize);
    string str = *stream;
    cout << str << endl;
    return iRealSize;
}

class Proc
{
    const char* cUrl;
    const char* cConsKey;
    const char* cConsSec;
    const char* cAtokKey;
    const char* cAtokSec;
    CURL        *curl;
    char*       cSignedUrl;
    string      chunk;
public:
    Proc(const char*, const char*, const char*, const char*, const char*);
    void execProc();
};

// Constructor
Proc::Proc(
    const char* cUrl,
    const char* cConsKey, const char* cConsSec,
    const char* cAtokKey, const char* cAtokSec)
{
    this->cUrl     = cUrl;
    this->cConsKey = cConsKey;
    this->cConsSec = cConsSec;
    this->cAtokKey = cAtokKey;
    this->cAtokSec = cAtokSec;
}

void Proc::execProc()
{
    // ==== cURL Initialization
    curl_global_init(CURL_GLOBAL_ALL);
    curl = curl_easy_init();
    if (!curl) {
        cout << "[ERROR] curl_easy_init" << endl;
        curl_global_cleanup();
        return;
    }

    // ==== cURL Setting
    // - URL, POST parameters, OAuth signing method, HTTP method, OAuth keys
    cSignedUrl = oauth_sign_url2(
        cUrl, NULL, OA_HMAC, "GET",
        cConsKey, cConsSec, cAtokKey, cAtokSec
    );
    // - URL
    curl_easy_setopt(curl, CURLOPT_URL, cSignedUrl);
    // - User agent name
    curl_easy_setopt(curl, CURLOPT_USERAGENT, "mk-mode BOT");
    // - HTTP STATUS >=400 ---> ERROR
    curl_easy_setopt(curl, CURLOPT_FAILONERROR, 1);
    // - Callback function
    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, fncCallback);
    // - Write data
    curl_easy_setopt(curl, CURLOPT_WRITEDATA, (void *)&chunk);

    // ==== Execute
    int iStatus = curl_easy_perform(curl);
    if (!iStatus)
        cout << "[ERROR] curl_easy_perform: STATUS=" << iStatus << endl;

    // ==== cURL Cleanup
    curl_easy_cleanup(curl);
    curl_global_cleanup();
}

int main(int argc, const char *argv[])
{
    // ==== Constants - URL
    const char *URL = "https://stream.twitter.com/1.1/statuses/sample.json";
    // ==== Constants - Twitter kyes
    const char *CONS_KEY = "<YOUR_CONSUMER_KEY>";
    const char *CONS_SEC = "<YOUR_CONSUMER_SECRET>";
    const char *ATOK_KEY = "<YOUR_ACCESS_TOKEN>";
    const char *ATOK_SEC = "<YOUR_ACCESS_TOKEN_SECRET>";

    // ==== Instantiation
    Proc objProc(URL, CONS_KEY, CONS_SEC, ATOK_KEY, ATOK_SEC);

    // ==== Main proccess
    objProc.execProc();

    return 0;
}

2. C++ ソースコードコンパイル

-Wall は警告も出力するオプション、 -O2 は最適化のオプション、 -lcurl, -loauth は curl, oauth ライブラリを読み込むオプション)

1
# g++ -Wall -O2 -o TwitterStream TwitterStream.cpp -lcurl -loauth

3. 動作確認

以下のように実行。(終了は CTLR-C で)

1
2
3
# ./TwitterStream

====< 延々に JSON データが出力される >====

参考サイト


Public Streams / sample でなく User Streams から取得するように変更したり、取得した JSON を解析する処理等を実装すれば有益なものになるでしょう。

以上。

Comments