質問: Embulkを使って、OracleDBのデータをBigQueryへバルクインサートする際に5000万件ほどのデータを処理すると一部スキップされてしまいます。 embulkの定義ファイルで指定したカラムの型と Bigquery側で生成されるテーブルのカラムの型は 一致しているのですが、一部レコードがスキップされる事象が発生する原因を知りたいです。 ``` ●Embulk定義ファイル in: type: file path_prefix: C:\Users\xxx\Desktop\embulk\DATA_CSV parser: type: csv delimiter: ',' skip_header_line: false charset: UTF-8 newline: CRLF quote: '"' escape: '"' trim_if_not_quoted: false skip_header_lines: 0 allow_extra_columns: false allow_optional_columns: true columns: - {name: ORDER_NO, type: string} - {name: ORG_CODE, type: string} - {name: TRAN_DATE, type: timestamp, format: '%Y/%m/%d'} - {name: CANCEL_FLAG, type: string} - {name: ACT_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'} - {name: WH_ACT_CREATION_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'} - {name: SUB_NO, type: string} - {name: UPDATE_REQUEST_ID, type: string} - {name: TIME_STAMP, type: timestamp, format: '%Y/%m/%d %H:%M:%S'} - {name: INV_UPDATE_FLAG, type: string} - {name: ISSUE_SEQ, type: string} - {name: BACKUP_DATE, type: timestamp, format: '%Y/%m/%d %H:%M:%S'} - {name: SOUMEI_ID, type: string} - {name: GCPCS_IF_FLAG, type: string} out: {type: bigquery, auth_method: json_key, json_keyfile: 'C:\Users\yazaki\Desktop\embulk\My First Project-6041ffecfba7.json', project: fluid-emissary-216806, dataset: embulk_test, auto_create_table: true, table: CSV_BQ_TABLE, open_read_timeout_sec: 360000, send_timeout_sec: 360000, read_timeout_sec: 360000} ●embulk実行後に、BigQuery側に生成されたテーブルレイアウト フィールド名 タイプ モード ORDER_NO STRING NULLABLE ORG_CODE STRING NULLABLE TRAN_DATE TIMESTAMP NULLABLE HINBAN STRING NULLABLE QTY STRING NULLABLE SUB_SYSTEM_TYPE1 STRING NULLABLE CANCEL_FLAG STRING NULLABLE ACT_CREATION_DATE TIMESTAMP NULLABLE WH_ACT_CREATION_DATE TIMESTAMP NULLABLE JOB_CODE STRING NULLABLE TIME_STAMP TIMESTAMP NULLABLE INV_UPDATE_FLAG STRING NULLABLE ISSUE_SEQ STRING NULLABLE BACKUP_DATE TIMESTAMP NULLABLE C_NO STRING NULLABLE T_NO STRING NULLABLE RECV_OFFICE_CODE STRING NULLABLE INV_INFO_UPDATE_FLAG STRING NULLABLE tmp STRING NULLABLE ``` ``` ●実行結果 ・ (中略) ・ 2019-02-15 09:12:04.801 +0900 [INFO] (0001:transaction): {done: 8 / 79, running: 7} 2019-02-15 09:12:04.985 +0900 [WARN] (0025:task-0015): Skipped line 82 (org.embulk.spi.time.TimestampParseException: Cannot parse '2018/09/21' by '%Y/%m/%d %H:%M:%S'): "35401536","2","8000","ZPD",2018/10/07,"L571ZW3SDWBD",10,"7NARTLDPH","66",0,"7500","BM0","UIIQ7LOGNI","PLPJ","WJWYWDZFFDZGUUDAQUH","7800","VOP","PH4GRLMBJ1","FNYZPJD","UGFYHBHIPZBCNPZIYKIWWHANJKHUEQ","L","0",2018/09/21,,"J",,"0","TCLJHNVEKMGBJZKQNBNPWJANCBSZXNBATJKB","ZVT","V","JLIMJN","FJWJMJDNBI","JQWOQAHU",,"F","1","J",,,,,,"AFNGJHJJQKFZIR",,"LJBQYC",,2018/12/04 12:11:13,"U","LBBTSNDFV",2018/12/03 09:30:44,,"1",,"WOK","HDU","ZBDGZEZ","JWP","X",,"JK","ZX","AEYM","1",,"1",,"IMN","S","HCFZNQ","KIHHWY","A","AUMN","B","FZVKGUAUYEXZOXWUBPMYECZBTCXVZXNCXI",,"KJ3",,,"IE","QZQNAHMCWBYKZ","14","1", ・ (中略) ・ ```
回答: エラー・メッセージの途中に > > Cannot parse '2018/09/21' by '%Y/%m/%d %H:%M:%S') > > > とあるから、 '2018/09/21' by '%Y/%m/%d' と書式マスクを変更するか、 '2018/09/21 00:00:00' by '%Y/%m/%d %H:%M:%S' とデータの変更が必要なのでは?