aws-lambda-stream
aws-lambda-stream copied to clipboard
add timestream support
-
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"),
// },
// };