役に立つものからたたないものまでTips集
グループからはお引っ越しできないんのんね。。。
バインディングされていない言語からgroongaにアクセスする
例えばJavaとか。というかJavaとかJavaとかJavaとか。自分で書けばいいのかもしれないが、Javaはよく知らないのであった(かけないことはないけどさ
お手軽なのはHTTPプロトコルを使うやつ。8083でgroonga httpサーバをたてておいてクライアントのコマンドラインからクエリを送る。
公式によると
HTTPでGroongaサーバーと通信する際には、以下のような形式でコマンドを指定します。:
Format: /d/COMMAND_NAME.OUTPUT_TYPE?ARGUMENT_NAME1=VALUE1&ARGUMENT_NAME2=VALUE2&...
とのことなのでselectコマンドを送ってJSONデータを得たい場合はCOMMAND_NAME="select", OUTPUT_TYPE="json"である。
$ curl "http://localhost:8083/d/select.json?table=00"
改行が…まあ読みたいときはXMLにすればいいわね
データのロードはPOSTをつかうのでブラウザからはたぶんできない(ファイルを読み込ませるならいけそうだが)
$ curl --data-binary '[{"_key":123123123, "record0_index":123123123, "record0_index.src_ip":121212}]' -H "Content-Type: application/json" "http://localhost:8083/d/load?table=record"
groongaを使う
昨日はいきなりマルチスレッドとかいい始めてしまいましたがやっぱちゃんと書かないとだめだなと気持ちを改めました…
ソースコードからビルド
昨日書いたとおりだが、githubからクローンしてくる
$ git clone --recursive git@github.com:groonga/groonga.git $ cd groonga $ cmake . $ make && sudo make install
installしたくない場合はmake installは不要
アクセス方法
ちょっとよくわかってないんだが、groongaへのアクセス方法は3つある
デフォルトではGQTPが使われるらしい。このGQTPはマルチスレッド対応しており(HTTPとかもしてるけど)、特に指定しなくてもマルチスレッドで使用できる。なおサーバーを特に起動させずスタンドアロンで使用する場合もマルチスレッドで動くので、DBをopenしたらスタンドアロンサーバーが立ち上がってるんじゃないかな?よくわかんないけど。
HTTPはポートがデフォルトだと10041みたいなので自分で適当なポートを設定したい時は
$ groonga -p 8085 --protocol http -d /tmp/test.db
などとする。 -dオプションはデーモン化するやつ。
DBを作成する
DBはファイルベースになっている。簡単なのはコマンドから作るやつ
$ groonga -n /tmp/test.db
デフォルトだと/var/lib/groonga/db/に作られる…のかな?サーバー立ち上げると特に指定しない場合はそこにできるみたい。
Cのソースコードから作る場合は下記の通り。
#include <groonga.h> int main(void) { grn_ctx ctx; grn_obj* db; grn_init(); grn_ctx_init(&ctx, 0); //オープンする。なかったら作る GRN_DB_OPEN_OR_CREATE(&ctx, path, 0, db); //確実にある場合はオープンするだけでもよい //db = grn_db_open(&ctx, path); grn_obj_close(&ctx, db); grn_ctx_fin(&ctx); return 0; }
テーブルを作成する
色々とオプションはあるのだが多分簡単に使うだけなら、もととなるテーブルと全文検索用インデックステーブルさえ作っておけば良さそう。
ただし全文検索用インデックスはカラムに対して紐付けを行うので、テーブルを作成する時はnormalizer_typeとtoken_bigramだけをしていしておけばよい。
コマンドラインで作る時は
> table_create --name "main_table" --flags "TABLE_HASH_KEY" --key_type "UInt32" > table_create --name "index_name" --flags "TABLE_PAT_KEY_TYPE" --key_type "SHORT_TEXT_TYPE" --normalizer "NormalizerAuto" --default_tokenizer "TokenBigram"
おまじないみたいなもんだとおもっとけ。キーのタイプだけは指定しないといけないのとインデックス作ろうと思うとHASH_KEYタイプにしなきゃいけないみたいだが、インデックスいらないならキーのないタイプもあるのでそのあたりはよく読もう。
オープン・クローズするソースコードにテーブル作るのを足してみる。ちなみに存在確認用のAPIはないので自分で工夫しないといけない
bool create_grn_table(grn_ctx* ctx, char *_name, char *_flags, char *_key_type, char *_norm, char *_token) { grn_obj *command, *name, *type, *flag, *norm, *token; char* result; uint32_t result_length; int32_t recv_flags; //grn_ctx_getで存在しない名前を指定した場合はNULLがかえる。これを利用して存在チェックする if(!grn_ctx_get(ctx, _name, strlen(_name)) { command = grn_ctx_get(ctx, "table_create", strlen("table_create")); name = grn_expr_get_var(ctx, command, "name", strlen("name")); flag = grn_expr_get_var(ctx, command, "flags", strlen("flags")); type = grn_expr_get_var(ctx, command, "key_type", strlen("key_type")); norm = grn_expr_get_var(ctx, command, "normalizer", strlen("normalizer")); token = grn_expr_get_var(ctx, command, "default_tokenizer", strlen("default_tokenizer")); grn_obj_reinit(ctx, name, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, flag, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, type, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, norm, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, token, GRN_DB_TEXT, 0); GRN_TEXT_PUTS(ctx, name, _table_name); GRN_TEXT_PUTS(ctx, type, _key_type); GRN_TEXT_PUTS(ctx, flag, _flags); GRN_TEXT_PUTS(ctx, norm, _normalizer); GRN_TEXT_PUTS(ctx, token, _tokenizer); grn_expr_exec(ctx, command, 0); grn_ctx_recv(ctx, &result, &result_length, &recv_flags); grn_expr_clear_vars(ctx, command); //unlinkでメモリから解放しておかないとメモリーリークが発生する。 //再帰的に開放されるのでgrn_ctx_getで取ってきたオブジェクトだけで良いみたい grn_obj_unlink(ctx, command); return memcmp(result, "true", result_length) == 0; } return true; } int main(void) { grn_ctx ctx; grn_obj* db; grn_init(); grn_ctx_init(&ctx, 0); //オープンする。なかったら作る GRN_DB_OPEN_OR_CREATE(&ctx, path, 0, db); //確実にある場合はオープンするだけでもよい //db = grn_db_open(&ctx, path); //create table create_grn_table(&ctx, "main_table", "TABLE_HASH_KEY", "UInt32", "", ""); create_grn_table(&ctx, "index_name", "TABLE_PAT_KEY", "ShortText", "NormalizerAuto", "TokenBigram"); grn_obj_close(&ctx, db); grn_ctx_fin(&ctx); return 0; }
この時点ではテーブルには_idと_keyがある(かくれて_scoreとかもあるが)。まだインデックステーブルとテーブルの関係性はできていないので次はカラムをつくる
なお、grn_table_createというAPIもあるのでこっちを使っても良い。が、noramlizerオプションとかdefault tokenをどうやって指定するのかよくわからない
カラムをつくる
基本的にはスカラー型でつくるのだが、インデックスの場合だけは指定する型が違う。あと関連をもたせたりとかもしないといけない。実はカラムってのが重要なんじゃないか?
まずはメインテーブルにname, valueのカラムを追加する
> column_create --table "main_table" --name "name" --flags "COLUMN_SCALAR" --type "ShortText" > column_create --table "main_table" --name "value" --flags "COLUMN_SCALAR" --type "UInt32"
インデックステーブルにカラムを追加する
main_tableのnameは文字列なので全部検索のためにインデックスを作成してる。
> column_create --table "index_name" --name "index_name_col" --flags "COLUMN_INDEX|WITH_POSITION" --type "main_table" --source "name"
注意するのはtypeに指定するのがもととなるテーブル名、sourceにインデックスを作成したいカラム名を指定することくらいかな。これでmain_tableにデータを追加あすると自動的にindex_nameテーブルも更新されるようになる
Cで書くとこんな具合。
bool create_grn_table(char *_name, char *_flags, char *_key_type, char *_norm, char *_token) { (省略) } bool create_grn_column(grn_ctx* ctx, char* _table, char* _column, char* _flags, char* _type, char* _sources) { grn_obj *command, *table, *name, *flag, *type, *source; char* result; uint32_t result_length; int32_t recv_flags; if(!grn_ctx_get(ctx, _column, strlen(_column)) { command = grn_ctx_get(ctx, "column_create", strlen("column_create")); table = grn_expr_get_var(ctx, command, "table", strlen("table")); name = grn_expr_get_var(ctx, command, "name", strlen("name")); flag = grn_expr_get_var(ctx, command, "flags", strlen("flags")); type = grn_expr_get_var(ctx, command, "type", strlen("type")); source = grn_expr_get_var(ctx, command, "source", strlen("source")); grn_obj_reinit(ctx, table, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, name, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, flag, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, type, GRN_DB_TEXT, 0); grn_obj_reinit(ctx, source, GRN_DB_TEXT, 0); GRN_TEXT_PUTS(ctx, table, _table); GRN_TEXT_PUTS(ctx, name, _column); GRN_TEXT_PUTS(ctx, flag, _flags); GRN_TEXT_PUTS(ctx, type, _type); GRN_TEXT_PUTS(ctx, source, _sources); grn_expr_exec(ctx, command, 0); grn_ctx_recv(ctx, &result, &result_length, &recv_flags); grn_expr_clear_vars(ctx, command); grn_obj_unlink(ctx, command); return memcmp(result, "true", result_length) == 0; } return true; } int main(void) { grn_ctx ctx; grn_obj* db; grn_init(); grn_ctx_init(&ctx, 0); //オープンする。なかったら作る GRN_DB_OPEN_OR_CREATE(&ctx, path, 0, db); //確実にある場合はオープンするだけでもよい //db = grn_db_open(&ctx, path); //create table create_grn_table(&ctx, "main_table", "TABLE_HASH_KEY", "UInt32", "", ""); create_grn_table(&ctx, "index_name", "TABLE_PAT_KEY", "ShortText", "NormalizerAuto", "TokenBigram"); //create column create_grn_column(&ctx, "main_table", "name", "COLUMN_SCALAR", "ShortText", ""); create_grn_column(&ctx, "main_table", "value", "COLUMN_SCALAR", "UInt32", ""); create_grn_column(&ctx, "index_name", "index_name_col", "COLUMN_INDEX|WITH_POSITION", "main_table", "name"); grn_obj_close(&ctx, db); grn_ctx_fin(&ctx); return 0; }
こっちもgrn_column_createというAPIがある。ただしsourceの指定はどうやってするのかよくわからない。typeは指定できるんだが、、、
マルチスレッドでgroongaを使う
いきなりgroongaってなんぞやって感じですが、ElasticSearchみたいなもんです。ライブラリがCなのでCから高速に使いたいときはこっちを使うと楽です。日本人が開発してるので日本語完全対応もうれしい。もうちょっとドキュメント整理してほしいけど、、、
http://groonga.org/ja/docs/index.html
(ちょっとおまけ)static ライブラリを作りたい
staticライブラリを作りたい時もありますよね?ありますよね?(白目
groongaはcmakeで楽ちんに作れますが、--help-property-listで出力してもstaticライブラリを作れそうなプロパティが出てきません。configureしてもいいけどどうしてもcmakeでやりたい。。。大丈夫。GRNG_EMBED=onとしてビルドすればできます。
まずはソースコードをダウンロードします。
git clone --recursive git@github.com:groonga/groonga.git
オプション付きでビルドします
cmake . -DGRNG_EMBED=on
libの下にlibgroonga.aができます。
ちなみにこれで作ったlibgroonga.aをリンクする際は一緒につくられるonigmoライブラリへのリンクもいっしょに追加しないといけません(onigmoを使わない場合は不要です)
例)
gcc -o sample main.c -L(groonga root)/lib -L(groonga root)/vendor/onigmo -lgroonga -ldl -lstdc++ -lonigmo -lz -lm
libstdc++, libmはbuild-essentialをインストールしたらだいたい一緒に入ると思うがlibdl, libzはlibltdl, zlib1gをインストールしないとだめみたい。
マルチスレッドで使う
よーやく本題。
groongaはマルチスレッド対応で特になにか設定をする必要はないようなことを書いてあるが、よーく読むとgrn_ctxは各スレッドに対して一つ与えてやらないといけないらしい。
ためしにinsert/deleteをマルチスレッドでやるサンプルを書いてみます。
#include <stdlib.h> #include <stdio.h> #include <groonga.h> #include <pthread.h> #define DATA(str, key) sprintf(str, "[{¥"_key¥":¥"%d¥",¥"value¥":¥"value¥"}]", key); grn_ctx ctx_insert; grn_ctx ctx_delete; grn_obj* open(grn_ctx* ctx, const char* path) { grn_obj* db; int i = 0; //grn_ctxオブジェクトの初期化 ctx = grn_ctx_open(0); grn_ctx_init(ctx, 0); //DBが存在しない場合は作成する。ある場合は開いてctxと関連付ける GRN_DB_OPEN_OR_CREATE(ctx, path, 0, db); //JSONで出力させる grn_ctx_set_output_type(ctx, GRN_CONTENT_JSON); return db; } int close(grn_ctx* ctx, grn_obj* db) { grn_obj_close(ctx, db); return grn_ctx_fin(ctx); } int insert_record(grn_ctx* ctx, char* data) { //レコードを追加する処理 } int delete_record(grn_ctx* ctx, char* key) { //レコードを冊書する処理 } void *insert(void* arg) { int i = 0; char str[128]; for(i = 0; i < 100; i++) { DATA(str, i); insert_record(&ctx_insert, str); } } void *delete(void* arg) { usleep(100); int i = 0; char index[2]; for(i = 0; i < 100; i++) { sprintf(index, "%2d", i); delete_record(&ctx_delete, index); } } int main(void) { grn_init(); grn_obj* db_insert = open(&ctx_insert, "db"); //おなじDBなので同じオブジェクトを使い回せば良いのではと思ったが今のところうまく行ってないので grn_obj* db_delete = open(&ctx_delete, "db"); //pthreadでスレッドを作り、joinさせて動かす pthread_t delete_th, insert_th; pthread_create(&insert_th, NULL, insert, NULL); pthread_create(&delete_th, NULL, delete, NULL); pthread_join(insert_th, NULL); pthread_join(delete_th, NULL); close(&ctx_insert, db_insert); close(&ctx_delete, db_delete); //一回で良い grn_fin(); return 0; }
割りと省略しまくりですが、大事なのはgrn_ctx, grn_dbをそれぞれのスレッドに対して作ること。
複数のクライアントからThriftサーバに接続する方法(C++)
あんま書いてなかったので。Javaでは見つかったんだけどC++だと需要ないの?
- calculator.thrift
namespace cpp example service Calculator { i64 add(1:i32 num1, 2:i32 num2); }
適当に足し算するメソッドを用意する
- server.cpp
#include "gen-cpp/Calculator.h" #include <thrift/protocol/TBinaryProtocol.h> #include <thrift/server/TSimpleServer.h> #include <thrift/transport/TServerSocket.h> #include <thrift/transport/TBufferTransports.h> #include <thrift/processor/TMultiplexedProcessor.h> #include <iostream> #include <thread> #include <chrono> using namespace ::apache::thrift; using namespace ::apache::thrift::protocol; using namespace ::apache::thrift::transport; using namespace ::apache::thrift::server; using boost::shared_ptr; using namespace ::example; class CalculatorHandler : virtual public CalculatorIf{ public: CalculatorHandler(){} //addの実装 int64_t add(const nt32_t num1, const int32_t num2){ std::this_thread::sleep_for(std::chrono::milliseconds(2000)); return num1 + num2; } }; int main(int argc, char** argv) { int port = 9090; shared_ptr<CalculatorHandler> handler(new CalculatorHandler()); //実行するプロセスのインスタンスを複数用意する shared_ptr<TProcessor> processor(new CalculatorProcessor(handler)); shared_ptr<TProcessor>remoteProcessor(new CalculatorProcessor(handler)); shared_ptr<TServerTransport> serverTransport(new TServerSocket(port)); shared_ptr<TTransportFactory> transportFactory(new TBufferedTransportFactory()); shared_ptr<TProtocolFactory> protocolFactory(new TBinaryProtocolFactory()); //メインのプロセス shared_ptr<TMultiplexedProcessor> mprocessor(new TMultiplexedProcessor()); //名前をつけてメインプロセスに実行プロセスを登録する mprocessor->registerProcessor("Calculator", processor); mprocessor->registerProcessor("remoteCalculator", processor); TSimpleServer server(mprocessor, serverTransport, transportFactory, protocolFactory); server.server(); return 0; }
- client.cpp
#include <iostream> #include <thrift/protocol/TBinaryProtocol.h> #include <thrift/transportt/TSocket.h> #include <thrift/transport/TTransportUtils.h> #include <thrift/protocol/TMultiplexedProtocol.h> #include "gen-cpp/Calculator.h" using namespace apache::thrift; using namespace apache::thrift::protocol; using namespace apache::thrift::transport; using namespace ::example; int main(int argc, char** argv) { //ホントはちゃんと処理しないとだめだけど第一引数がプロセス名とする string protocolName = argv[1]; boost::shared_ptr<TTransport> socket(new TSocket("localhost", 9090)); boost::shared_ptr<TTransport> transport(new TBufferedTransport(socket)); boost::shared_ptr<TBinaryProtocol> protocol(new TBinaryProtocol(transport)); //複数接続する用のプロトコルを使う。名前で識別する boost::shared_ptr<TMultiplexedProtocol> mp(new TMultiplexedProtocol(protocol, protocolName.c_str())); CalculatorClient client(mp); transport->open(); int val = client.add(1, 2); std::cout << val << std::endl; transport->close(); return 0; }
マルチスレッドじゃないんで先に撮った方のプロセスの処理が終わるまで待ちが発生するけど、同じポートに二つのクライアントプロセスから接続して処理させるのはできました。あ、ビルド時にlibthread.aにリンクしてね
おしゃれなCLI Argument Parser、Docopt.cppを使ってみた
GitHub - docopt/docopt.cpp: C++11 port of docopt
Pythonとかの情報はあるのだがC++はあんまりないので書いとく。
Docoptはgetoptやprogram_optionsのようなCLIから実行するときのコマンドやオプションを解析してくれるパーサなのだが、とにかく使い方がエレガントだ。注意点はGCC4.8だとなんかいろいろ大変ってことだろうか。GCC4.8を使っている場合については後述。
基本
かきかたはgithubにも書いてあるし、ここにもあるが、違うサンプルでかいてみる。
#include <docopt.h> //別にコードと同じ階層にdocoptのライブラリをコピーしてきても良いが綺麗じゃないのでわけた #include <iostream> //USAGEで定義する文字列の中にUsage: Options: でUsageとOptionsを指定するだけであとはよろしくやってくれる //exampleではなぜかcharを使っているが実装はstd::stringだった。いやまぁ暗黙で変換してくれるけどさ… static const std::string USAGE = R"(test Usage: test start (o <option> -p <option2> | -q <option3> [-d dir -v] test stop [now] test (-h | --help) test --version Options: -o option Set option -p option2 Set option2 -q option3 Set option3 -d dir Set directory -v Debug print -h --help Print help --version Print version )"; int main(int argc, const char** argv) { //コマンドラインで指定する引数を最初のバイナリ名だけは飛ばして最後までvectorに格納するらしい std::vector<std::string> arg {argv + 1, argv + argc}; //最後の引数に表示するバージョンスクリプトを指定 std::map<std::string, docopt::value> args = docopt::docopt(USAGE, arg, true, "SampleProgram v0.0.1"); //mapのキーはOptionsで指定したオプション名。値を取らないオプションの場合、docopt::valueはboolになる。それ以外はstd::string //helpとversionは特に実装しなくていいが、それ以外のオプションについては以降で処理を記述する //例 if(args["start"].asBool() == true) { std::cout << "stat" << std::endl; if((std::string)args["-o"].asString() != "") { //do something } } return 0; }
Usageを書けばそれにそってパースしてくれるというのがスマートでよい。コンパイルする場合はlibdocopt.aをリンクしよう。
GCC4.9以上が普通に入ってる場合
$ g++ -o test test.cpp -I<docoptdir> -ldocopt
GCC4.8以下の場合でGCC4.9を無理やり入れた場合は
$ g++-4.9 -o test test.cpp -I<docoptdir> -L/usr/lib/gcc/x86_64-linux-gnu/4.9 -lstdc++ -ldocopt
libstdc++のリンクをしないといけない。
GCC4.9を無理やり入れてGCC4.9でdocoptをコンパイルする方法
C++11 regex using g++ | GeekWentFreak
ここにかいてあるとおりやればよい。
$ sudo add-apt-repository ppa:ubuntu-toolchain-r/test $ sudo apt-get update $ sudo apt-get install g++-4.9
無理にgcc4.9を使うのでCMakeList.txtをいじってもいいけど自分でコンパイルすることにする(cmakeはよくわからん)
$ g++-4.9 --std=c++11 -D__cplusplus=201103L -D__GXX_EXPERIMENTAL_CXX0X__ -o docopt.o docopt.cpp docopt.h docopt_value.h docopt_util.h docopt_private.h $ ar -r "libdocopt.a" ./docopt.o
あれ?これでいいのかな?まぁEclipseで適当に設定してShared Libraryを作ってください
これでできたlibdocopt.aを使わないとregex関係のリンクが上手くできない
ちなみにgcc4.9以上が入っててもCMake3.2未満だとコンパイルできないのでとりあえずcmake3.2は入れる。
$ sudo apt-get install build-essential $ wget http://www.cmake.org/files/v3.2/cmake-3.2.2.tar.gz $ tar xf cmake-3.2.2.tar.gz $ cd cmake-3.2.2 $ ./configure $ make $ sudo apt-get install checkinstall $ sudo checkinstall $ sudo make install
そんでおもむろにライブラリを作る。
$ cmake . $ make
一度つかえるようになればかなり相当楽になる。
constのついた引数からconstを取る
constになっちまうのは困るんだろ?
こまるぅ!
というわけでconst_castですね
http://d.hatena.ne.jp/tmatsuu/20090717/1247835994
int fun(const char* bar){ char *foo = const_cast<char*>(bar); }