// Code generated by smithy-go-codegen DO NOT EDIT. package timestreamwrite import ( "context" "fmt" awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware" "github.com/aws/aws-sdk-go-v2/aws/signer/v4" internalEndpointDiscovery "github.com/aws/aws-sdk-go-v2/service/internal/endpoint-discovery" "github.com/aws/aws-sdk-go-v2/service/timestreamwrite/types" "github.com/aws/smithy-go/middleware" smithyhttp "github.com/aws/smithy-go/transport/http" ) // 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 (https://docs.aws.amazon.com/kms/latest/developerguide/concepts.html#aws-managed-cmk) // . Service quotas apply (https://docs.aws.amazon.com/timestream/latest/developerguide/ts-limits.html) // . For details, see code sample (https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.create-batch-load.html) // . func (c *Client) CreateBatchLoadTask(ctx context.Context, params *CreateBatchLoadTaskInput, optFns ...func(*Options)) (*CreateBatchLoadTaskOutput, error) { if params == nil { params = &CreateBatchLoadTaskInput{} } result, metadata, err := c.invokeOperation(ctx, "CreateBatchLoadTask", params, optFns, c.addOperationCreateBatchLoadTaskMiddlewares) if err != nil { return nil, err } out := result.(*CreateBatchLoadTaskOutput) out.ResultMetadata = metadata return out, nil } type CreateBatchLoadTaskInput struct { // Defines configuration details about the data source for a batch load task. // // This member is required. DataSourceConfiguration *types.DataSourceConfiguration // Report configuration for a batch load task. This contains details about where // error reports are stored. // // This member is required. ReportConfiguration *types.ReportConfiguration // Target Timestream database for a batch load task. // // This member is required. TargetDatabaseName *string // Target Timestream table for a batch load task. // // This member is required. TargetTableName *string // ClientToken *string // DataModelConfiguration *types.DataModelConfiguration // RecordVersion *int64 noSmithyDocumentSerde } type CreateBatchLoadTaskOutput struct { // The ID of the batch load task. // // This member is required. TaskId *string // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata noSmithyDocumentSerde } func (c *Client) addOperationCreateBatchLoadTaskMiddlewares(stack *middleware.Stack, options Options) (err error) { err = stack.Serialize.Add(&awsAwsjson10_serializeOpCreateBatchLoadTask{}, middleware.After) if err != nil { return err } err = stack.Deserialize.Add(&awsAwsjson10_deserializeOpCreateBatchLoadTask{}, middleware.After) if err != nil { return err } if err = addSetLoggerMiddleware(stack, options); err != nil { return err } if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil { return err } if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil { return err } if err = addResolveEndpointMiddleware(stack, options); err != nil { return err } if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil { return err } if err = addRetryMiddlewares(stack, options); err != nil { return err } if err = addHTTPSignerV4Middleware(stack, options); err != nil { return err } if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil { return err } if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil { return err } if err = addClientUserAgent(stack, options); err != nil { return err } if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil { return err } if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil { return err } if err = addOpCreateBatchLoadTaskDiscoverEndpointMiddleware(stack, options, c); err != nil { return err } if err = addIdempotencyToken_opCreateBatchLoadTaskMiddleware(stack, options); err != nil { return err } if err = addOpCreateBatchLoadTaskValidationMiddleware(stack); err != nil { return err } if err = stack.Initialize.Add(newServiceMetadataMiddleware_opCreateBatchLoadTask(options.Region), middleware.Before); err != nil { return err } if err = awsmiddleware.AddRecursionDetection(stack); err != nil { return err } if err = addRequestIDRetrieverMiddleware(stack); err != nil { return err } if err = addResponseErrorMiddleware(stack); err != nil { return err } if err = addRequestResponseLogging(stack, options); err != nil { return err } return nil } func addOpCreateBatchLoadTaskDiscoverEndpointMiddleware(stack *middleware.Stack, o Options, c *Client) error { return stack.Serialize.Insert(&internalEndpointDiscovery.DiscoverEndpoint{ Options: []func(*internalEndpointDiscovery.DiscoverEndpointOptions){ func(opt *internalEndpointDiscovery.DiscoverEndpointOptions) { opt.DisableHTTPS = o.EndpointOptions.DisableHTTPS opt.Logger = o.Logger opt.EndpointResolverUsedForDiscovery = o.EndpointDiscovery.EndpointResolverUsedForDiscovery }, }, DiscoverOperation: c.fetchOpCreateBatchLoadTaskDiscoverEndpoint, EndpointDiscoveryEnableState: o.EndpointDiscovery.EnableEndpointDiscovery, EndpointDiscoveryRequired: true, }, "ResolveEndpoint", middleware.After) } func (c *Client) fetchOpCreateBatchLoadTaskDiscoverEndpoint(ctx context.Context, input interface{}, optFns ...func(*internalEndpointDiscovery.DiscoverEndpointOptions)) (internalEndpointDiscovery.WeightedAddress, error) { in, ok := input.(*CreateBatchLoadTaskInput) if !ok { return internalEndpointDiscovery.WeightedAddress{}, fmt.Errorf("unknown input type %T", input) } _ = in identifierMap := make(map[string]string, 0) key := fmt.Sprintf("Timestream Write.%v", identifierMap) if v, ok := c.endpointCache.Get(key); ok { return v, nil } discoveryOperationInput := &DescribeEndpointsInput{} opt := internalEndpointDiscovery.DiscoverEndpointOptions{} for _, fn := range optFns { fn(&opt) } endpoint, err := c.handleEndpointDiscoveryFromService(ctx, discoveryOperationInput, key, opt) if err != nil { return internalEndpointDiscovery.WeightedAddress{}, err } weighted, ok := endpoint.GetValidAddress() if !ok { return internalEndpointDiscovery.WeightedAddress{}, fmt.Errorf("no valid endpoint address returned by the endpoint discovery api") } return weighted, nil } type idempotencyToken_initializeOpCreateBatchLoadTask struct { tokenProvider IdempotencyTokenProvider } func (*idempotencyToken_initializeOpCreateBatchLoadTask) ID() string { return "OperationIdempotencyTokenAutoFill" } func (m *idempotencyToken_initializeOpCreateBatchLoadTask) HandleInitialize(ctx context.Context, in middleware.InitializeInput, next middleware.InitializeHandler) ( out middleware.InitializeOutput, metadata middleware.Metadata, err error, ) { if m.tokenProvider == nil { return next.HandleInitialize(ctx, in) } input, ok := in.Parameters.(*CreateBatchLoadTaskInput) if !ok { return out, metadata, fmt.Errorf("expected middleware input to be of type *CreateBatchLoadTaskInput ") } if input.ClientToken == nil { t, err := m.tokenProvider.GetIdempotencyToken() if err != nil { return out, metadata, err } input.ClientToken = &t } return next.HandleInitialize(ctx, in) } func addIdempotencyToken_opCreateBatchLoadTaskMiddleware(stack *middleware.Stack, cfg Options) error { return stack.Initialize.Add(&idempotencyToken_initializeOpCreateBatchLoadTask{tokenProvider: cfg.IdempotencyTokenProvider}, middleware.Before) } func newServiceMetadataMiddleware_opCreateBatchLoadTask(region string) *awsmiddleware.RegisterServiceMetadata { return &awsmiddleware.RegisterServiceMetadata{ Region: region, ServiceID: ServiceID, SigningName: "timestream", OperationName: "CreateBatchLoadTask", } }