質問編集履歴
2
inを追記
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -11,6 +11,17 @@
|
|
|
11
11
|
**試した内容**
|
|
12
12
|
embulkのoutの内容に以下を追加
|
|
13
13
|
```ここに言語を入力
|
|
14
|
+
in:
|
|
15
|
+
type: mysql
|
|
16
|
+
database: {{ env.SRC_DB_DATABASE }}
|
|
17
|
+
user: {{ env.SRC_DB_USERNAME }}
|
|
18
|
+
password: {{ env.SRC_DB_PASSWORD }}
|
|
19
|
+
host: {{ env.SRC_DB_HOST }}
|
|
20
|
+
query: {{ query }}
|
|
21
|
+
port: 3306
|
|
22
|
+
options: {useLegacyDatetimeCode: false, serverTimezone: Etc/UTC, characterEncoding: UTF-8}
|
|
23
|
+
socket_timeout: 30
|
|
24
|
+
|
|
14
25
|
out:
|
|
15
26
|
type: mysql
|
|
16
27
|
database: {{ env.DEST_DB_DATABASE }}
|
1
outを追記
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -20,7 +20,12 @@
|
|
|
20
20
|
port: 3306
|
|
21
21
|
table: {{ table }}
|
|
22
22
|
mode: truncate_insert
|
|
23
|
-
options: { tinyInt1isBit: false }
|
|
23
|
+
options: { tinyInt1isBit: false } ← こちらを追加
|
|
24
|
+
escape: '"'
|
|
25
|
+
parser:
|
|
26
|
+
type: json
|
|
27
|
+
column_options:
|
|
28
|
+
inserted_at: {type: 'timestamp default current_timestamp'}
|
|
24
29
|
```
|
|
25
30
|
→結果すべて1が入ってしまう｡
|
|
26
31
|
embulkのinのクエリで以下のように設定
|