処理が正常に終了し、actor_testテーブルが作成され、データが転送されているが確認できました。

今回は、同一のデータベース（sakila）内で行いましたが、同MySQLサーバ上ですが別のデータベースに対しても同様に処理された事を確認。

この程度の簡単なお試し処理で意味がありませんが、並列処理されていることが実行情報より見てとれます。

[INFO] (0001:transaction): Using local thread executor with max_threads=8 / output tasks 4 = input tasks 1 * 4

出力（out：）をCSVファイルにすると、タスク数（プロセッサ数：お試し用PCは4つのロジカルプロセッサ）分のCSVファイルが作成されます。

タスク数やスレッド数はオプションで設定できリーソースに合わせて処理の並列化が可能です。

次に、embulk-output-mysql のmergeモードを試してみるInsert/Updateで差分更新ができる様子。

差分更新用にMySQLにテーブルを作成

use test;

CREATE TABLE `actor_test` (

`actor_id` smallint(5) unsigned NOT NULL,

`first_name` varchar(45) NOT NULL,

`last_name` varchar(45) NOT NULL,

`last_update` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,

PRIMARY KEY (`actor_id`),

KEY `idx_actor_last_name` (`last_name`)

) ENGINE=InnoDB AUTO_INCREMENT=201 DEFAULT CHARSET=utf8;

差分更新（merge）用の処理をエディタにて作成

mysql_actor_test_sync.yml

-------------------------------------------

in:

type: mysql

host: localhost

user: kano

password: tkano

database: sakila

table: actor_test

select: "*"

out:

type: mysql

host: localhost

user: kano

password: tkano

database: test

table: actor_test

mode: merge

-------------------------------------------

事前にsakila.actor_testテーブルのデータをtes.actor_testテーブルに転送

　MAX(sakila.actor_test.actor_id) = 200

　MAX(test.actor_test.actor_id) = 200

差分（とりあえずactor_idで）がないことを確認。

Embulk