1
0
mirror of synced 2025-12-21 19:11:14 -05:00
Commit Graph

2421 Commits

Author SHA1 Message Date
Yurii Bidiuk
0187efd030 Destination BigQuery: update description for some fields (#9573)
* update desrcription for bq destination setup

* bump version
2022-01-18 21:59:01 +02:00
Koji Matsumoto
3f9cbecbaf Destination BigQuery: Accept Dataset ID field prefixed by Project ID (#8383)
* add Dataset ID parse method

* add BigQuery Destination unit test

* update change log

* fit to the latest code base

* update change log

* change var name to const name

* change public method to private

* add test cases for testGetDatasetIdFail

* add integration test for dataset-id prefixed with project-id

* fix getDatasetId

* add comment to parameterized test provider

* update docker image versions

* update docker image versions again
2022-01-18 14:41:12 +02:00
Álvaro Queiroz
41f89d1ab2 Destination S3: use instanceprofile if credentials are not provided (#9399)
* use instanceprofile to auth if id is not provided

* restore support for using endpoint

* update readme

* update changelog

* update documentation, add setup guide

* Update docs/integrations/destinations/s3.md

Co-authored-by: Edward Gao <edward.gao@airbyte.io>

* minor fixes

* add error message

* now using RuntimeException

* Update airbyte-integrations/connectors/destination-s3/src/main/java/io/airbyte/integrations/destination/s3/S3DestinationConfig.java

Co-authored-by: Edward Gao <edward.gao@airbyte.io>

* bump connector version

* update seed file

Co-authored-by: Edward Gao <edward.gao@airbyte.io>
Co-authored-by: Marcos Marx <marcosmarxm@gmail.com>
2022-01-13 21:32:26 -03:00
Augustin
71f5b1cd71 🎉 Destination DynamoDB: rename dynamodb_table_name to dynamodb_table_name_prefix (#9314) 2022-01-13 19:15:34 +01:00
Andrii Leonets
c904b44998 BigQuery Destination : Fix GCS processing of Facebook data (#9415)
* Fix GCS Avro file processing with invalid "-" character

* Extend test data to cover the case

* incr ver

* s3 ver upd

* add dependency

* add dependency
2022-01-13 19:16:20 +02:00
bmatt
80666cf117 Destination Azure Blob Storage: Added BufferedOutputStream to fix block count issue and improve performance (#9190) 2022-01-12 10:09:37 +01:00
LiRen Tu
5f6785dcbf 🐞 Destination S3 & GCS Avro: support array with unknown item type (#9367)
* Support array field with empty items specification

* Remove all exceptions

* Format code

* Bump connector versions

* Bump bigquery versions

* Update docs

* Remove unused code

* Update doc for PR #9363

* Update doc about defaulting all improperly typed fields to string

* Ignore bigquery

* Update version and doc

* Update doc

* Bump version in seed
2022-01-11 23:12:37 -08:00
Eugene
44cb30aca5 🐛Destination-gcs\destination-bigquery(gcs) - updated check() method to handle that user has both storage.objects.create and storage.multipartUploads.create roles (#9121)
* [9044] Destination-gcs\destination-bigquery(gcs) - updated check() method to handle that user has both storage.objects.create and storage.multipartUploads.create roles
2022-01-10 22:00:16 +02:00
VitaliiMaltsev
1054e7e916 Destination Snowflake : fixed duplicate rows on retries (#9141)
* fix for jdk 17

* Destination Snowflake: duplicate rows on retries

* added changelog

* fix checkstyle

* replace concat with +

* replaced static fields and methods with non-static

* bump version

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2022-01-10 21:26:38 +02:00
oneshcheret
ceaa1a478e 🐛 Snowflake destination: do not create schema if it exists (#9311)
* Snowflake destination: do not create schema if it exists

* Snowflake destination: move common constants to parent class

* Snowflake destination: bump version

* Snowflake destination: bump version
2022-01-10 14:30:52 +02:00
Iryna Grankova
8237a70ce9 🎉 Destination databricks: update fields specifications (#9153)
* Files title/description update for issue # 8948

* Version update for issue # 8948

* Changelogs update for PR #9153

* Update changelog

Co-authored-by: LiRen Tu <tuliren@gmail.com>
Co-authored-by: Liren Tu <tuliren.git@outlook.com>
2022-01-06 21:16:46 -08:00
Charles
e80d6140d2 📖 Clarify staging setup guide for bq & gcs destination (#9255)
* clarify confusing parts of setting up staging for bq destination

* Added Storage Admin

* update gcs destination docs too

* fix indentation

* Update required permission list

Co-authored-by: Liren Tu <tuliren.git@outlook.com>
2022-01-06 14:34:49 -08:00
Edward Gao
b6926d44d4 🚨 Snowflake produces permanent tables 🚨 (#9063) 2022-01-06 10:10:25 -08:00
Iryna Grankova
9de7443ec0 Update fields in destination-connectors specifications: mssql, mssql-strict-encrypt (#9158)
* Files title/description update for issue # 8950

* Version update for issue # 8950

* Changelogs update for PR #9158

* update destination_specs.yaml with new version

* update version for destination-mssql-strict-encrypt

* fix destination-mssql-strict-encrypt integration tests

Co-authored-by: mkhokh <mariia.khokh@globallogic.com>
2022-01-04 14:10:51 +02:00
Iryna Grankova
099c896ded Update fields in destination-connectors specifications: gcs, jdbc, kafka, keen, kinesis, kvdb, local-json, mariadb-columnstore, mongodb (#8809)
* Files title/description update for issue # 8747

Co-authored-by: Serhii Chvaliuk <grubberr@gmail.com>
2021-12-30 16:21:35 +02:00
Iryna Grankova
7ecc9ac4ef Update fields in destination-connectors specifications: meilisearch (#9156)
* Files title/description update for issue # 8949

* Version update for issue # 8949

* Changelogs update for PR #9156

* bump version

Co-authored-by: alvova <annalvova05@gmail.com>
2021-12-29 13:33:34 +02:00
Alexander Tsukanov
eea41b4fc8 🎉 Destination Snowflake and RedShift: Implement the Byte-buffered logic (#8869)
* airbyte-8336: Byte based approach.

* test-commit

* airbyte-8336: Split file by cnhunks.

* airbyte-8336: Renamed variable.

* airbyte-8336: make snowflake DEFAULT_MAX_BATCH_SIZE_BYTES_SNOWFLAKE constant.

* airbyte-8336: make snowflake DEFAULT_MAX_BATCH_SIZE_BYTES_SNOWFLAKE constant.

* airbyte-8336: make snowflake DEFAULT_MAX_BATCH_SIZE_BYTES_SNOWFLAKE constant.

* airbyte-8336: fix of unit tests

* airbyte-8336: Changed to default buffer size in SnowFlake.

* airbyte-8336: Changed 15 GB to 1 GB for max size.

* airbyte-8336: Changed to default buffer size in SnowFlake.

* airbyte-8336: Bumped connector version.

* airbyte-8336: Bumped connector version.

* airbyte-8336: Bumped connector version.
2021-12-24 12:32:10 +02:00
Yurii Bidiuk
14c3536d2f 🐛 Destination Snowflake | BigQuery: add part_size config to UI (#9039)
* add part_size to Snowflake-s3, Bihquery-gcs

* add part size for bigquery-denormalized

* update changelog md

* add limints for part size

* update bigquery version
2021-12-23 22:23:26 +02:00
Sherif A. Nada
6316cb920c Update bigquery.md 2021-12-21 15:22:36 -08:00
Sherif A. Nada
0210071599 Update Bigquery docs page 2021-12-21 15:18:59 -08:00
James Zhao
5dad5de932 Destination ClickHouse: Fix destination IllegalStateException (#8982) 2021-12-21 21:27:07 +01:00
VitaliiMaltsev
287cdb5faf 🐛 Destination Snowflake SQL compilation error (#9006)
* fix for jdk 17

* updated SnowflakeDatabase jdbc connection params

* updated spec.json

* updated spec.json

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-12-21 21:32:16 +02:00
VitaliiMaltsev
a3100cba8f 🐛 Destination S3: avro and parquet formats have issues with JsonToAvroSchemaConverter (#8574)
* add namespace to avro record type

* refactoring

* Add unit tests

* added CHANGELOG

* fix typo in method name

* fix typo in method name

* fix for jdk 17

* created recursive keys adding

* refactoring

* format code

* cleanup Dockerfile

* refactoring

* removed unneded tests case

* updated namespace generation

* removed unneeded method from AvroNameTransformer

* resolved merge conflicts

* removed unused imports

* reformat the code

* bump version

* bump Bigquery Denormalized version

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
Co-authored-by: Oleksandr Sheheda <alexandrshegeda@gmail.com>
2021-12-21 17:51:48 +02:00
LiRen Tu
9b75a76720 📑 Update source database performance test docs (#8980)
* Add missing pr number

* Update source database performance test docs

* Update doc

* Update script paths
2021-12-20 20:49:22 -08:00
LiRen Tu
a6c2d058a9 🐞 Destination S3 & GCS: remove excessive logging (#8974)
* Bump s3 and gcs version

* Bump version in seed
2021-12-20 17:47:55 -08:00
Andrii Leonets
637fac3483 BigQuery/BiqQuery denorm Destinations : Add possibility to use different types of GCS files (#8788)
* impl BigQuery uploader

* rework BigQuery destination in order to use Uploaders

* fix constructor

* fix test

* add job waiting

* fix correct closing

* Throw exception if something goes wrong.

* Move data format logic to the formatters.

* remove duplication from tests

* JsonToAvro schema transformation

* destination-bigquery: print BQ error when sync fails

* add uploader config

* uncommit table drop

* switch to S3 json converter + disable invalid tests

* fix test stuck

* move getSchema to formatters

* replace Date-time to Timestamp for the Denormalized Avro processing. BigQuery doesn't support direct transformation from file.

* make test in line with GCS impl

* add string type for Ref fields (GCS impl)

* fix format root of NULL with nested date-time fields

* adopt array processing

* minor fix

* fix incorrect array filtering

* format

* Connector throw error after close no more.

* uncommit fixed tests

* format

* Add GCS to denormalized spec

* Increase version

* fix s3 tests

* review upd

* fix gcs

* format + minor beautifier

* revert docker file change

* correct condition

* Update airbyte-integrations/connectors/destination-s3/src/main/java/io/airbyte/integrations/destination/s3/avro/AvroRecordFactory.java

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* Update airbyte-integrations/connectors/destination-bigquery-denormalized/src/main/resources/spec.json

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* Update airbyte-integrations/connectors/destination-bigquery-denormalized/src/main/resources/spec.json

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* Update airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/formatter/BigQueryRecordFormatter.java

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* don't throw warns during record formatting

* add back adding String to all logical avro S3 types controlled by param.

* add docs

* fix internal call.

* fix GCS AVRO integration test

* Update airbyte-integrations/connectors/destination-bigquery/src/main/java/io/airbyte/integrations/destination/bigquery/uploader/AbstractGscBigQueryUploader.java

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* Update airbyte-integrations/connectors/destination-gcs/src/main/java/io/airbyte/integrations/destination/gcs/util/GcsUtils.java

Co-authored-by: LiRen Tu <tuliren@gmail.com>

* remove unused code

* remove duplication in BigQuery formatters

* replace group file delete to specific file delete to avoid deleting unfinished loads

* restore docker files

* Revert "restore docker files"

This reverts commit 0a06d81852.

* resolved conflicts

* Update airbyte-integrations/connectors/destination-bigquery/Dockerfile

Co-authored-by: mkhokh <mariia.khokh@globallogic.com>
Co-authored-by: LiRen Tu <tuliren@gmail.com>
Co-authored-by: Oleksandr Sheheda <alexandr.shegeda@gmail.com>
Co-authored-by: Sherif A. Nada <snadalive@gmail.com>
2021-12-20 19:00:04 +02:00
LiRen Tu
6ee29b5b82 🐞 Destination e2e test: fix documentation url (#8905)
* Fix documentation url

* Update pr url

* Update doc

* Bump version
2021-12-19 19:34:26 -08:00
LiRen Tu
0de30f5e4d 🎉 Testing destination: multiple logging modes (#8824)
* Implement destination null

* Update existing testing destinations

* Merge in logging consumer

* Remove old destination null

* Add documentation

* Add destination to build and summary

* Fix test

* Update acceptance test

* Log state message

* Remove unused variable

* Remove extra statement

* Remove old null doc

* Add dev null destination

* Update doc to include changelog for dev null

* Format code

* Fix doc

* Register e2e test destination in seed
2021-12-19 00:33:42 -08:00
Edward Gao
86e08d0fa4 🎉 Destination Redshift: add option to enable/disable deleting staging data (#8855) 2021-12-17 12:42:09 -08:00
Edward Gao
7038533ae0 🎉 Destination Redshift (copy): accept bucket path for staging data (#8607) 2021-12-16 16:41:22 -08:00
VitaliiMaltsev
91513f5e58 Destination Snowflake: update check method to verify permissions for staging (#8781)
* Destination Snowflake update check method to verify permission for stages

* fix for jdk 17

* fix for jdk 17

* fix with ci secrets

* fix with ci secrets

* removed snowflake secrets from ci_credentials.sh

* bump version

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-12-16 12:01:21 +02:00
Christophe Duong
3740f25a2c BigQuery locations update (#8816)
* Update bigquery dataset locations

* Update BQ denormalized locations too

* Bumpversion bq destinations
2021-12-16 10:48:16 +01:00
sbaldwin-rs
3748c66daa 🎉 New Destination: Rockset (#8006) 2021-12-15 15:53:58 +01:00
maciej-nedza
cbcd6e3732 update chargify documentation (#8764) 2021-12-14 21:00:13 -03:00
Bo Lu
bbcd461bc5 🎉 New Destination: ClickHouse (#7620)
* add ClickHouse destination

* update docs

* format code

* code improvement as per code review

* add ssh tunneling and ssl/tls support and code enhancement

* merge from master

* disable testCustomDbtTransformationsFailure test

* fix string format bug

* fix reserved keywords bug and disable dbt

* disable dbt in expect result

* add type hints

* bump connector version

Co-authored-by: Alexander Tsukanov <alexander.tsukanovvv@gmail.com>
Co-authored-by: Marcos Marx <marcosmarxm@gmail.com>
2021-12-13 19:39:19 -03:00
Luis Gomez
cba7285c99 🎉 New destination: RabbitMQ (#7560)
* Added RabbitMQ destination

* Added unit tests

* Added exchange to config

* Updated to support different connection parameters

* Added integration tests

* Added RabbitMQ destination documentation

* small change

* Addressed PR comments

* add creds

* format files

* bump connector config files version

* run format

Co-authored-by: Marcos Marx <marcosmarxm@gmail.com>
2021-12-13 19:11:32 -03:00
Edward Gao
0b8c0f5dff Bump connector versions for publishing (#8717)
version bumps for https://github.com/airbytehq/airbyte/pull/8562
2021-12-10 19:27:26 -08:00
Edward Gao
fc91f67747 move S3Config into destination-s3; update dependencies accordingly (#8562) 2021-12-10 15:51:25 -08:00
Alasdair Brown
84b3bf55ac 🎉 Destination Amazon SQS: New connector (#7503)
* initial commit, working sending single messages

* Adds Unit Tests, removes un-implemented features from Spec, yields sent messages, fixed fifo suffix match, adds bootstrap

* Remove yield from RECORD message

* Complete readme for sqs

* Formatting

* Minor tidying of unit tests

* Add references in docs pages

* formatting

* Add docs links

* formatting
2021-12-10 03:51:51 +05:30
VitaliiMaltsev
f9d8e39592 Destination Snowflake: Return Standard Loading (#8528)
* Snowflake Destination: implemented internal staging

* fix checkstyle

* improved perfomance of sync

* added changelog

* test refactoring

* removed file chunking

* add docs

* added javadoc, updated spec

* refactoring

* bump version

* return Standard Inserts into spec

* hide Standard inserts option, set Internal staging as default option

* remove hidden: true from spec

* bump version 0.3.19

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-12-06 22:39:32 +02:00
LiRen Tu
804fe6bcb7 Bump s3 version to remove excessive logging (#8501)
* Bump s3 version to remove excessive logging

* Bump seed version and update spec
2021-12-03 15:41:14 -08:00
Augustin
7b81e11a19 Publish new GCS region (#8392)
* add new region

* update seed files for destination-gcs

* add region northamerica-northeast2

* update changelog

* Change version to 0.1.15

* Revert version in seed before publishing

* Bump seed version and update sepc

Co-authored-by: Antonio G <antonio@datascope.io>
Co-authored-by: Liren Tu <tuliren.git@outlook.com>
Co-authored-by: LiRen Tu <tuliren@gmail.com>
2021-12-03 15:28:25 -08:00
Antonio Grass
2c34c70a07 🎉 Destination GCS: add new region (#8386)
* add new region

* update seed files for destination-gcs

* add region northamerica-northeast2

* update changelog

Co-authored-by: alafanechere <augustin.lafanechere@gmail.com>
2021-12-03 15:24:25 -08:00
oneshcheret
fcf7491fee 🐛 Validate incorrect handling '\n' symbols in ssh key (#8371)
* 🐛 Validate \n in ssh key

* bump versions for ssh key connectors

* update versions for ssh key connectors

* temporal fix for checking failed tests

* revert temp changes and destination oracle version

* bump versions in config for ssh key related connectors
2021-12-03 20:11:51 +02:00
VitaliiMaltsev
d3ac897c8f 🎉 Snowflake Destination internal staging support (#8253)
* Snowflake Destination: implemented internal staging

* fix checkstyle

* improved perfomance of sync

* added changelog

* test refactoring

* removed file chunking

* add docs

* added javadoc, updated spec

* refactoring

* bump version

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-12-03 15:31:12 +02:00
VitaliiMaltsev
67f7cf01f2 Bump GCS version with avro/parquet timestamp conversion (#8360)
* get date-time format form json schema

* created universal date-time converter

* implemented jsonnode transformation for avro and parquet

* removed unneeded dependency from build.gradle

* fix checkstyle

* add DateTimeUtilsTest

* add AvroRecordHelperTest

* resolve merge conflicts | fix checkstyle

* update LocalTime parsing

* added String type to avro schema for Logical Types, removed date-time conversion

* fix checkstyle

* fix checkstyle

* added static String schema, added comments

* bump version

* Bump GCS version with avro/parquet timestamp conversion

* update docs

* update docs

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-12-02 10:32:35 +02:00
VitaliiMaltsev
065bbf60da 🎉 Destination S3 Support writing timestamps (#7732)
* get date-time format form json schema

* created universal date-time converter

* implemented jsonnode transformation for avro and parquet

* removed unneeded dependency from build.gradle

* fix checkstyle

* add DateTimeUtilsTest

* add AvroRecordHelperTest

* resolve merge conflicts | fix checkstyle

* update LocalTime parsing

* added String type to avro schema for Logical Types, removed date-time conversion

* fix checkstyle

* fix checkstyle

* added static String schema, added comments

* bump version

Co-authored-by: vmaltsev <vitalii.maltsev@globallogic.com>
2021-11-30 12:08:36 +02:00
Madison Swain-Bowden
b28f20bb53 🎉 New Destination: SFTP JSON (#4924) 2021-11-24 15:23:21 +01:00
Koji Matsumoto
694cbed455 🎉 New Destination: MariaDB ColumnStore (#7961) 2021-11-23 19:31:27 +01:00
Ivica Taseski
0eba52e002 🎉 New destination: Kinesis (#7799)
* add kinesis destination connector

* format code

* add javadoc and general documentation

* fix buffer bug and refactor code

* rename vars to common airbyte usage

* run format

* run format + seed file

* add eof

Co-authored-by: Marcos Marx <marcosmarxm@gmail.com>
2021-11-21 23:17:38 -03:00