Embulk(エンバルク)プラグインのまとめ - Qiita
embulk gem search embulk-filter -r 2015-05-30 18:20:50.064 +0900: Embulk v0.6.10 *** REMOTE GEMS *** embulk-filter-eval (0.1.0) embulk-filter-speedometer (0.2.2) Inputプラグイン RDBMS & NoSQL Embulk(エンバルク) データベースプラグイン覚書も参照ください。 embulk-input-mysql MySQLのテーブルからデータを取得するJDBCプラグイン embulk-input-postgresql PostgreSQLのテーブルからデータを取得するJDBCプラグイン embulk-input-jdbc JDBC用プラグイン Oracleなど接続用 Oracleは使えるはずDB2は要書き換え。 SQLit
Embulkのコマンドヘルプまとめ - Qiita
Embulk v0.8.3 Usage: embulk [-vm-options] <command> [--options] Commands: mkbundle <directory> # create a new plugin bundle environment. bundle [directory] # update a plugin bundle environment. run <config.yml> # run a bulk load transaction. cleanup <config.yml> # cleanup resume state. preview <config.yml> # dry-run the bulk load without output and show preview. guess <partial-config.yml> -o <outp
Embulkローカルファイル出力メモ(Hishidama's Embulk output-local-file Memo)
S-JIS[2015-08-09/2021-12-19] 変更履歴 Embulk ローカルファイルの出力 Embulkのローカルファイル書き込みのメモ。 概要 ローカルファイルはデフォルトで（追加プラグイン無しで）出力できる。 ファイルの形式はフォーマッターで指定する。 圧縮して出力したい場合はエンコーダーを指定する。 ローカルファイル出力で出力されるカラム（項目）は、入力データの全カラムになる。 カラム名も入力時に付けられたカラム名が使用される。 カラム名を変えたり、カラムの並び順を変えたり、出力するカラムを選択したりしたい場合は、フィルターを使う。 csvファイルの例 config.yml： in: ～ out: type: file path_prefix: /tmp/example/result/store_info file_ext: csv formatter: type: c
Embulk(エンバルク)組み込みプラグインの設定覚え書き - Qiita
Embulk組み込みプラグインの設定覚え書き その他の情報はFluentdのバッチ版Embulkのまとめをご覧ください。 Embulkには組み込みでいくつかのプラグインが用意されています。この資料ではEmbukの基本的な概念を説明したのち、組み込みのプラグインについて解説をおこないます。 詳細は、オフィシャルのマニュアルを参照してください。Configuration (英語) 1, レコード、カラム、そして型 Embulkは、内部でデータをレコードとして取り扱いします。 レコードは、複数のカラムから構成されるデータ1件のことを表します。 例えば住所録では、人1名の情報がレコードです。1名の情報には、氏名や 年齢といったその人固有の情報があります。この固有の情報一つ一つが カラムです。それぞれのカラムには型があります。姓や名であれば文字列、 年齢であれば数字(整数)、生年月日であれば日付(日
Embulk の Timestamp クラスまわりのメモ (Java) - Qiita
Java な embulk プラグインを作るにあたって、Timestamp オブジェクトの作り方とか、format の仕方とか parse の仕方とか。 JRuby の機能を使ったりしていて、けっこうややこしい(それ自体は %Y-%m-%d のような Ruby ライクな時間フォーマットを使えるようにするためなので仕方ないのだが) Timestamp オブジェクトの作り方 cf. http://www.embulk.org/docs/javadoc/org/embulk/spi/time/Timestamp.html ただ Timestamp オブジェクトを作るだけであれば、 Timestamp.ofEpochSecond(long epochSecond); Timestamp.ofEpochSecond(long epochSecond, long nanoAdjustMent); Ti
Embulkフィルターメモ(Hishidama's Embulk filter Memo)
S-JIS[2015-08-09/2015-09-27] 変更履歴 Embulk フィルター Embulkのフィルターのメモ。 概要 Embulkでは、読み込んだデータを多少加工することが出来る。 これはフィルタープラグインで行う。 出力系のプラグインには、フィルターで加工された後のデータが渡される。 カラム名変更フィルター 入力時に付けられたカラム名を変更するには、「type: rename」のフィルターを使う。 例えば、idというカラム名をsample_id、accountをaccount_idに変更するには、以下の様に記述する。 config.yml： in: ～ filters: - type: rename columns: id: sample_id account: account_id out: type: stdout 実行例： $ embulk preview conf
EmbulkでMySQLに4GB突っ込んで測ってみた - 今日もプログラミング
Embulkを使えば、いろいろなデータを簡単にDBに突っ込めるはず。 でも、パフォーマンスが気になるよね。 という訳で、Embulkのパフォーマンスを測ってみることにした。 環境の準備 自分のマシンでパフォーマンステストをすると他のことができなくなってしまうので、AWSを使うことにした。 インスタンスタイプはどうしようか？ マルチスレッドを試したいので4CPU欲しい。DB入れるのでメモリもある程度必要だ。ディスクはSSDだとちょっと速過ぎる気がするし、EBSだと遅い気がするし…、とかいろいろ考えて、結局旧世代のm1.xlargeにしてしまった。 OSは自分のマシンに合わせてWindows。JavaとかMySQLもインストールする。 MySQLのチューニングとかは特にしていない（あまり詳しくないので…）。 Embulkもダウンロードした。このときの最新は0.5.0。 embulk-outpu
Embulkローカルファイル入力メモ(Hishidama's Embulk input-local-file Memo)
S-JIS[2015-08-09/2017-07-16] 変更履歴 Embulk ローカルファイルの入力 Embulkのローカルファイル読み込みのメモ。 概要 ローカルファイルはデフォルトで（追加プラグイン無しで）読み込める。 ファイルの形式はパーサーで指定する。 圧縮されているファイルを読み込みたい場合はデコーダーを指定する。 embulkのguessコマンドでローカルファイルを読み込み、レイアウトを推測してymlファイルを生成することが出来る。 csvファイルの例 config.yml： in: type: file path_prefix: /tmp/example/master/store_info parser: type: csv charset: UTF-8 newline: CRLF delimiter: ',' quote: '"' escape: '\' null_st
Embulk: Configuration
Embulk configuration file format Embulk uses a YAML file to define a bulk data loading. Here is an example of the file: in: type: file path_prefix: ./mydata/csv/ decoders: - {type: gzip} parser: charset: UTF-8 newline: CRLF type: csv delimiter: ',' quote: '"' escape: '"' null_string: 'NULL' skip_header_lines: 1 columns: - {name: id, type: long} - {name: account, type: long} - {name: time, type: ti
1
リリース、障害情報などのサービスのお知らせ
最新の人気エントリーの配信
j次のブックマーク
k前のブックマーク
lあとで読む
eコメント一覧を開く
oページを開く
GitHub - mgi166/embulk-filter-eval: Eval ruby code on filtering