Closed jgilbert01 closed 5 days ago
connector - batch handling
sink
flavor/materialize-timestream
https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/timestream-write/command/WriteRecordsCommand/
https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.write.html
import { TimestreamWriteClient, WriteRecordsCommand } from "@aws-sdk/client-timestream-write"; // ES Modules import // const { TimestreamWriteClient, WriteRecordsCommand } = require("@aws-sdk/client-timestream-write"); // CommonJS import const client = new TimestreamWriteClient(config); const input = { // WriteRecordsRequest DatabaseName: "STRING_VALUE", // required TableName: "STRING_VALUE", // required CommonAttributes: { // Record Dimensions: [ // Dimensions { // Dimension Name: "STRING_VALUE", // required Value: "STRING_VALUE", // required DimensionValueType: "VARCHAR", }, ], MeasureName: "STRING_VALUE", MeasureValue: "STRING_VALUE", MeasureValueType: "DOUBLE" || "BIGINT" || "VARCHAR" || "BOOLEAN" || "TIMESTAMP" || "MULTI", Time: "STRING_VALUE", TimeUnit: "MILLISECONDS" || "SECONDS" || "MICROSECONDS" || "NANOSECONDS", Version: Number("long"), MeasureValues: [ // MeasureValues { // MeasureValue Name: "STRING_VALUE", // required Value: "STRING_VALUE", // required Type: "DOUBLE" || "BIGINT" || "VARCHAR" || "BOOLEAN" || "TIMESTAMP" || "MULTI", // required }, ], }, Records: [ // Records // required { Dimensions: [ { Name: "STRING_VALUE", // required Value: "STRING_VALUE", // required DimensionValueType: "VARCHAR", }, ], MeasureName: "STRING_VALUE", MeasureValue: "STRING_VALUE", MeasureValueType: "DOUBLE" || "BIGINT" || "VARCHAR" || "BOOLEAN" || "TIMESTAMP" || "MULTI", Time: "STRING_VALUE", TimeUnit: "MILLISECONDS" || "SECONDS" || "MICROSECONDS" || "NANOSECONDS", Version: Number("long"), MeasureValues: [ { Name: "STRING_VALUE", // required Value: "STRING_VALUE", // required Type: "DOUBLE" || "BIGINT" || "VARCHAR" || "BOOLEAN" || "TIMESTAMP" || "MULTI", // required }, ], }, ], }; const command = new WriteRecordsCommand(input); const response = await client.send(command); // { // WriteRecordsResponse // RecordsIngested: { // RecordsIngested // Total: Number("int"), // MemoryStore: Number("int"), // MagneticStore: Number("int"), // }, // };
connector - batch handling
sink
flavor/materialize-timestream
https://docs.aws.amazon.com/AWSJavaScriptSDK/v3/latest/client/timestream-write/command/WriteRecordsCommand/
https://docs.aws.amazon.com/timestream/latest/developerguide/code-samples.write.html