Skip to content

Commit bdf431e

Browse files
author
awstools
committed
feat(client-firehose): Allow support for Snowflake as a Kinesis Data Firehose delivery destination.
1 parent d7c4d31 commit bdf431e

File tree

6 files changed

+1172
-0
lines changed

6 files changed

+1172
-0
lines changed

clients/client-firehose/src/commands/CreateDeliveryStreamCommand.ts

+27
Original file line numberDiff line numberDiff line change
@@ -526,6 +526,33 @@ export interface CreateDeliveryStreamCommandOutput extends CreateDeliveryStreamO
526526
* Connectivity: "PUBLIC" || "PRIVATE", // required
527527
* },
528528
* },
529+
* SnowflakeDestinationConfiguration: { // SnowflakeDestinationConfiguration
530+
* AccountUrl: "STRING_VALUE", // required
531+
* PrivateKey: "STRING_VALUE", // required
532+
* KeyPassphrase: "STRING_VALUE",
533+
* User: "STRING_VALUE", // required
534+
* Database: "STRING_VALUE", // required
535+
* Schema: "STRING_VALUE", // required
536+
* Table: "STRING_VALUE", // required
537+
* SnowflakeRoleConfiguration: { // SnowflakeRoleConfiguration
538+
* Enabled: true || false,
539+
* SnowflakeRole: "STRING_VALUE",
540+
* },
541+
* DataLoadingOption: "JSON_MAPPING" || "VARIANT_CONTENT_MAPPING" || "VARIANT_CONTENT_AND_METADATA_MAPPING",
542+
* MetaDataColumnName: "STRING_VALUE",
543+
* ContentColumnName: "STRING_VALUE",
544+
* SnowflakeVpcConfiguration: { // SnowflakeVpcConfiguration
545+
* PrivateLinkVpceId: "STRING_VALUE", // required
546+
* },
547+
* CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
548+
* ProcessingConfiguration: "<ProcessingConfiguration>",
549+
* RoleARN: "STRING_VALUE", // required
550+
* RetryOptions: { // SnowflakeRetryOptions
551+
* DurationInSeconds: Number("int"),
552+
* },
553+
* S3BackupMode: "FailedDataOnly" || "AllData",
554+
* S3Configuration: "<S3DestinationConfiguration>", // required
555+
* },
529556
* };
530557
* const command = new CreateDeliveryStreamCommand(input);
531558
* const response = await client.send(command);

clients/client-firehose/src/commands/DescribeDeliveryStreamCommand.ts

+25
Original file line numberDiff line numberDiff line change
@@ -462,6 +462,31 @@ export interface DescribeDeliveryStreamCommandOutput extends DescribeDeliveryStr
462462
* // S3BackupMode: "FailedDataOnly" || "AllData",
463463
* // S3DestinationDescription: "<S3DestinationDescription>",
464464
* // },
465+
* // SnowflakeDestinationDescription: { // SnowflakeDestinationDescription
466+
* // AccountUrl: "STRING_VALUE",
467+
* // User: "STRING_VALUE",
468+
* // Database: "STRING_VALUE",
469+
* // Schema: "STRING_VALUE",
470+
* // Table: "STRING_VALUE",
471+
* // SnowflakeRoleConfiguration: { // SnowflakeRoleConfiguration
472+
* // Enabled: true || false,
473+
* // SnowflakeRole: "STRING_VALUE",
474+
* // },
475+
* // DataLoadingOption: "JSON_MAPPING" || "VARIANT_CONTENT_MAPPING" || "VARIANT_CONTENT_AND_METADATA_MAPPING",
476+
* // MetaDataColumnName: "STRING_VALUE",
477+
* // ContentColumnName: "STRING_VALUE",
478+
* // SnowflakeVpcConfiguration: { // SnowflakeVpcConfiguration
479+
* // PrivateLinkVpceId: "STRING_VALUE", // required
480+
* // },
481+
* // CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
482+
* // ProcessingConfiguration: "<ProcessingConfiguration>",
483+
* // RoleARN: "STRING_VALUE",
484+
* // RetryOptions: { // SnowflakeRetryOptions
485+
* // DurationInSeconds: Number("int"),
486+
* // },
487+
* // S3BackupMode: "FailedDataOnly" || "AllData",
488+
* // S3DestinationDescription: "<S3DestinationDescription>",
489+
* // },
465490
* // AmazonOpenSearchServerlessDestinationDescription: { // AmazonOpenSearchServerlessDestinationDescription
466491
* // RoleARN: "STRING_VALUE",
467492
* // CollectionEndpoint: "STRING_VALUE",

clients/client-firehose/src/commands/UpdateDestinationCommand.ts

+24
Original file line numberDiff line numberDiff line change
@@ -429,6 +429,30 @@ export interface UpdateDestinationCommandOutput extends UpdateDestinationOutput,
429429
* ProcessingConfiguration: "<ProcessingConfiguration>",
430430
* CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
431431
* },
432+
* SnowflakeDestinationUpdate: { // SnowflakeDestinationUpdate
433+
* AccountUrl: "STRING_VALUE",
434+
* PrivateKey: "STRING_VALUE",
435+
* KeyPassphrase: "STRING_VALUE",
436+
* User: "STRING_VALUE",
437+
* Database: "STRING_VALUE",
438+
* Schema: "STRING_VALUE",
439+
* Table: "STRING_VALUE",
440+
* SnowflakeRoleConfiguration: { // SnowflakeRoleConfiguration
441+
* Enabled: true || false,
442+
* SnowflakeRole: "STRING_VALUE",
443+
* },
444+
* DataLoadingOption: "JSON_MAPPING" || "VARIANT_CONTENT_MAPPING" || "VARIANT_CONTENT_AND_METADATA_MAPPING",
445+
* MetaDataColumnName: "STRING_VALUE",
446+
* ContentColumnName: "STRING_VALUE",
447+
* CloudWatchLoggingOptions: "<CloudWatchLoggingOptions>",
448+
* ProcessingConfiguration: "<ProcessingConfiguration>",
449+
* RoleARN: "STRING_VALUE",
450+
* RetryOptions: { // SnowflakeRetryOptions
451+
* DurationInSeconds: Number("int"),
452+
* },
453+
* S3BackupMode: "FailedDataOnly" || "AllData",
454+
* S3Update: "<S3DestinationUpdate>",
455+
* },
432456
* };
433457
* const command = new UpdateDestinationCommand(input);
434458
* const response = await client.send(command);

0 commit comments

Comments
 (0)