Граф коммитов

19 Коммитов

Автор SHA1 Сообщение Дата
Ben Wu 0f967c4b81
Output message if no data files are found for date (#21) 2020-10-13 14:52:12 -04:00
Ben Wu 5d5b16966d
Set lower chunksize for upload to gcs (#18) 2020-07-08 15:08:22 -04:00
Ben Wu 3fc83e224b
Ingest streaming data from s3 (#17) 2020-06-30 16:17:33 -04:00
Ben Wu 8675debdcb
Set schemas for external csv tables (#16) 2019-12-19 17:46:10 -05:00
Ben Wu ea4ed32763
Add destination dataset name to temp table name (fixes #11) (#13) 2019-12-12 12:36:49 -05:00
Ben Wu 4bdbd23b68
Increase max deletion size to 5000 (fixes #8) (#12) 2019-12-11 13:43:57 -05:00
Frank Bertsch 6ba1f2e249 Fix linting errors 2019-11-19 12:25:53 -05:00
Frank Bertsch 19922b50b7 Insert data into BQ native tables
See bug 1593268.
- Add an option for removing columns before load
- Partition table based on load date
- Delete partition before loading
- Create table on first load
- Move clients to be class vars
- Update tests
2019-11-19 12:22:11 -05:00
Frank Bertsch 3db14f802a Fix tests for new param 2019-10-21 20:41:13 -04:00
Wesley Dawson 5374f876aa
Avoid storage.buckets.get API call 2019-10-21 13:22:25 -07:00
Frank Bertsch c7d516a97d Add optional version number
This will deal with possible schema evolution issues. We will
simply increment the version and deal with it in a view.

This also requires table_prefix and version when
calling export, both of which are given defaul values
in the CLI.
2019-10-16 13:47:45 -04:00
Frank Bertsch f57a211954 Remove output from file and table names 2019-10-16 10:44:51 -04:00
Frank Bertsch cefd996b6a Add option for tablename prefix 2019-10-16 10:14:52 -04:00
Frank Bertsch cb9e41c1ac Lint; add ci linting 2019-10-14 10:20:52 -04:00
Frank Bertsch 88a1a4c88b Drop table if exists before creation 2019-10-14 10:09:48 -04:00
Frank Bertsch c3c5f9d417 Delete GCS prefix before writing 2019-10-14 10:05:11 -04:00
Frank Bertsch 5265071bd5 Add python export mechanism 2019-10-11 14:09:59 -04:00
Frank Bertsch 3380ceca92 Remove application leftovers 2019-10-11 14:09:21 -04:00
Frank Bertsch 1fa6dc869e Add initial skeleton for job 2019-10-08 11:07:55 -04:00