Treasure Dataのデータを利用するプログラム（Ruby編）

◆ Live配信スケジュール ◆
サイオステクノロジーでは、Microsoft MVPの武井による「わかりみの深いシリーズ」など、定期的なLive配信を行っています。
⇒ 詳細スケジュールはこちらから
⇒ 見逃してしまった方はYoutubeチャンネルをご覧ください

【5/21開催】Azure OpenAI ServiceによるRAG実装ガイドを公開しました
生成AIを活用したユースケースで最も一番熱いと言われているRAGの実装ガイドを公開しました。そのガイドの紹介をおこなうイベントです!!
https://tech-lab.connpass.com/event/315703/

こんにちは、SSTDの大村です。セミナーも終わりゆっくりしていたいところですが、新しいお客様にもめぐり合え、忙しい日々をすごしています。うれしいかぎりです。これからもさまざまなお客様と出会えるように精進していきます。

今回はTresureDataを利用するプログラムを書いてみようと思います。Treasure Dataの基本機能でできないことも、プログラムから操作すれば思うがまま、自由自在ですね。操作自体はとっても簡単なので、あとは他のアプリケーションなどと接続するプログラミングをすればよいだけなのです。今回はRubyからの操作を見てみましょう。

まずはじめにTreasure Dataにデータを入力するRubyプログラムを書きます。今回利用するRubyはTreasure Data Toolbeltをインストールしたときに一緒に入っているRubyを利用します。これでバージョン互換などを気にすることなくTreasure Dataを利用することができます。

1 前準備
2 データ入力用のプログラムの作成
3 データ取得用のプログラム作成

前準備

Treasure Data Toolbeltをインストール
apikeyを取得
$ td apikey:show
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
取得したapikeyを環境変数TD_API_KEYに登録（登録しない場合はapikeyをプログラム内に直に書いてください）

データ入力用のプログラムの作成

データ入力用のプログラムを作成します。忘れずにRuby用のtdライブラリをロードします。

td.testdbのtestdbがTreasure Dataのデータベース名、TD.event.postの後ろにデータを追加するテーブル名を指定します。

このプログラムはtd-agentを利用しているので、td-agent.confを記述し、td-agentを作動させている必要があります。まず下のようにtd-agent.confを設定します。

データの流れはプログラムからlocalのポート24224にデータが送信され、その後、td-agentの機能でTreasure Dataにデータが送信されるので、sourceタグの記述を省略することはできませんので注意してください。

td-agentを再起動します。

$ sudo /etc/init.d/td-agent restart
Shutting down td-agent: [ OK ]
Starting td-agent: [ OK ]

実行します。

$ ./td_input.rb

確認してみましょう。

$ td tables
+———-+—————–+——+———–+———+——————+——–+
| Database | Table | Type | Count | Size | Last import | Schema|
+———-+—————–+——+———–+———+——————+——–+
| testdb | input_test_tbl | log | 1 | 0.0 GB | 2013-05-22 17:53:02 +0900 ||
| testdb | www_access | log | 5,000 | 0.0 GB | 2013-05-14 10:34:04 +0900 ||
+———-+—————–+——+———–+———+——————+——-+
2 rows in set

新しいテーブルが作成され、データが１件入力されているのが確認できました。