转自:http://blog.csdn.net/post_yuan/article/details/77856320
用户也可以开发自己的plugins并上传,如EsgynDB就基于trafodion自己开发一款基于trafodion的upsert using load实现的批量加载插件,如下图,

本文在此利用上述的trafodion output插件及oracle input插件通过实例描述如何使用embulk实现oracle到trafodion的数据加载。
1 下载安装Embulk
<code>wget https:</code><code>//dl</code><code>.embulk.org</code><code>/embulk-latest</code><code>.jarmkdir ~/.embulk</code><code>/bin</code>
<code>mv</code> <code>embulk-latest.jar ~/.embulk</code><code>/bin/embulk</code>
<code>chmod</code> <code>+x ~/.embulk</code><code>/bin/embulk</code>
<code>echo</code> <code>'export PATH="$HOME/.embulk/bin:$PATH"'</code> <code>>> ~/.bashrc</code>
<code>source</code> <code>~/.bashrc123456</code>
2 验证Embulk下载安装成功
<code>[root@n12 ~]</code><code># embulk gem list</code>
<code>2017-09-05 20:19:51.184 +0800: Embulk v0.8.31</code>
<code>*** LOCAL GEMS ***</code>
<code>did_you_mean (default: 1.0.1)</code>
<code>jar-dependencies (default: 0.3.5)</code>
<code>jruby-openssl (0.9.17 java)</code>
<code>json (1.8.3 java)</code>
<code>minitest (default: 5.4.1)</code>
<code>net-telnet (default: 0.1.1)</code>
<code>power_assert (default: 0.2.3)</code>
<code>psych (2.0.17 java)</code>
<code>racc (1.4.14 java)</code>
<code>rake (default: 10.4.2)</code>
<code>rdoc (default: 4.2.0)</code>
<code>test</code><code>-unit (default: 3.1.1)</code>
3 安装oracle input插件及trafodion output插件
4 验证以上插件安装成功
5 准备oracle jar包,用于读取oracle数据库
6 编辑YAML文件oracle_to_trafodion.yml
7 创建Oracle测试表并插入测试数据
8 创建Trafodion目标表
9 运行Embulk任务
10 检查Embulk任务执行成功
至此,使用Embulk从Oracle抽取数据到Trafodion演示完毕!