import type { MetadataBearer as __MetadataBearer } from "@smithy/types"; import type { CreateBatchLoadTaskRequest, CreateBatchLoadTaskResponse } from "../models/models_0"; /** * @public */ export type { __MetadataBearer }; /** * @public * * The input for {@link CreateBatchLoadTaskCommand}. */ export interface CreateBatchLoadTaskCommandInput extends CreateBatchLoadTaskRequest { } /** * @public * * The output of {@link CreateBatchLoadTaskCommand}. */ export interface CreateBatchLoadTaskCommandOutput extends CreateBatchLoadTaskResponse, __MetadataBearer { } declare const CreateBatchLoadTaskCommand_base: { new (input: CreateBatchLoadTaskCommandInput): import("@smithy/core/client").CommandImpl; new (input: CreateBatchLoadTaskCommandInput): import("@smithy/core/client").CommandImpl; getEndpointParameterInstructions(): import("@smithy/types").EndpointParameterInstructions; }; /** *

Creates a new Timestream batch load task. A batch load task processes data from * a CSV source in an S3 location and writes to a Timestream table. A mapping from * source to target is defined in a batch load task. Errors and events are written to a report * at an S3 location. For the report, if the KMS key is not specified, the * report will be encrypted with an S3 managed key when SSE_S3 is the option. * Otherwise an error is thrown. For more information, see Amazon Web Services managed * keys. Service quotas apply. For * details, see code * sample.

* @example * Use a bare-bones client and the command you need to make an API call. * ```javascript * import { TimestreamWriteClient, CreateBatchLoadTaskCommand } from "@aws-sdk/client-timestream-write"; // ES Modules import * // const { TimestreamWriteClient, CreateBatchLoadTaskCommand } = require("@aws-sdk/client-timestream-write"); // CommonJS import * // import type { TimestreamWriteClientConfig } from "@aws-sdk/client-timestream-write"; * const config = {}; // type is TimestreamWriteClientConfig * const client = new TimestreamWriteClient(config); * const input = { // CreateBatchLoadTaskRequest * ClientToken: "STRING_VALUE", * DataModelConfiguration: { // DataModelConfiguration * DataModel: { // DataModel * TimeColumn: "STRING_VALUE", * TimeUnit: "MILLISECONDS" || "SECONDS" || "MICROSECONDS" || "NANOSECONDS", * DimensionMappings: [ // DimensionMappings // required * { // DimensionMapping * SourceColumn: "STRING_VALUE", * DestinationColumn: "STRING_VALUE", * }, * ], * MultiMeasureMappings: { // MultiMeasureMappings * TargetMultiMeasureName: "STRING_VALUE", * MultiMeasureAttributeMappings: [ // MultiMeasureAttributeMappingList // required * { // MultiMeasureAttributeMapping * SourceColumn: "STRING_VALUE", // required * TargetMultiMeasureAttributeName: "STRING_VALUE", * MeasureValueType: "DOUBLE" || "BIGINT" || "BOOLEAN" || "VARCHAR" || "TIMESTAMP", * }, * ], * }, * MixedMeasureMappings: [ // MixedMeasureMappingList * { // MixedMeasureMapping * MeasureName: "STRING_VALUE", * SourceColumn: "STRING_VALUE", * TargetMeasureName: "STRING_VALUE", * MeasureValueType: "DOUBLE" || "BIGINT" || "VARCHAR" || "BOOLEAN" || "TIMESTAMP" || "MULTI", // required * MultiMeasureAttributeMappings: [ * { * SourceColumn: "STRING_VALUE", // required * TargetMultiMeasureAttributeName: "STRING_VALUE", * MeasureValueType: "DOUBLE" || "BIGINT" || "BOOLEAN" || "VARCHAR" || "TIMESTAMP", * }, * ], * }, * ], * MeasureNameColumn: "STRING_VALUE", * }, * DataModelS3Configuration: { // DataModelS3Configuration * BucketName: "STRING_VALUE", * ObjectKey: "STRING_VALUE", * }, * }, * DataSourceConfiguration: { // DataSourceConfiguration * DataSourceS3Configuration: { // DataSourceS3Configuration * BucketName: "STRING_VALUE", // required * ObjectKeyPrefix: "STRING_VALUE", * }, * CsvConfiguration: { // CsvConfiguration * ColumnSeparator: "STRING_VALUE", * EscapeChar: "STRING_VALUE", * QuoteChar: "STRING_VALUE", * NullValue: "STRING_VALUE", * TrimWhiteSpace: true || false, * }, * DataFormat: "CSV", // required * }, * ReportConfiguration: { // ReportConfiguration * ReportS3Configuration: { // ReportS3Configuration * BucketName: "STRING_VALUE", // required * ObjectKeyPrefix: "STRING_VALUE", * EncryptionOption: "SSE_S3" || "SSE_KMS", * KmsKeyId: "STRING_VALUE", * }, * }, * TargetDatabaseName: "STRING_VALUE", // required * TargetTableName: "STRING_VALUE", // required * RecordVersion: Number("long"), * }; * const command = new CreateBatchLoadTaskCommand(input); * const response = await client.send(command); * // { // CreateBatchLoadTaskResponse * // TaskId: "STRING_VALUE", // required * // }; * * ``` * * @param CreateBatchLoadTaskCommandInput - {@link CreateBatchLoadTaskCommandInput} * @returns {@link CreateBatchLoadTaskCommandOutput} * @see {@link CreateBatchLoadTaskCommandInput} for command's `input` shape. * @see {@link CreateBatchLoadTaskCommandOutput} for command's `response` shape. * @see {@link TimestreamWriteClientResolvedConfig | config} for TimestreamWriteClient's `config` shape. * * @throws {@link AccessDeniedException} (client fault) *

You are not authorized to perform this action.

* * @throws {@link ConflictException} (client fault) *

Timestream was unable to process this request because it contains resource that * already exists.

* * @throws {@link InternalServerException} (server fault) *

* Timestream was unable to fully process this request because of an internal server * error.

* * @throws {@link InvalidEndpointException} (client fault) *

The requested endpoint was not valid.

* * @throws {@link ResourceNotFoundException} (client fault) *

The operation tried to access a nonexistent resource. The resource might not be * specified correctly, or its status might not be ACTIVE.

* * @throws {@link ServiceQuotaExceededException} (client fault) *

The instance quota of resource exceeded for this account.

* * @throws {@link ThrottlingException} (client fault) *

Too many requests were made by a user and they exceeded the service quotas. The request * was throttled.

* * @throws {@link ValidationException} (client fault) *

An invalid or malformed request.

* * @throws {@link TimestreamWriteServiceException} *

Base exception class for all service exceptions from TimestreamWrite service.

* * * @public */ export declare class CreateBatchLoadTaskCommand extends CreateBatchLoadTaskCommand_base { /** @internal type navigation helper, not in runtime. */ protected static __types: { api: { input: CreateBatchLoadTaskRequest; output: CreateBatchLoadTaskResponse; }; sdk: { input: CreateBatchLoadTaskCommandInput; output: CreateBatchLoadTaskCommandOutput; }; }; }