Für ähnliche Funktionen wie Amazon Timestream für sollten Sie Amazon Timestream for LiveAnalytics InfluxDB in Betracht ziehen. Es bietet eine vereinfachte Datenaufnahme und Antwortzeiten im einstelligen Millisekundenbereich für Analysen in Echtzeit. Erfahren Sie hier mehr.
Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Die Konfiguration des Partitionierungsschemas wird aktualisiert
Sie können die Tabellenkonfiguration für das Partitionierungsschema mit einem SDK mit Zugriff auf die UpdateTable
Aktion aktualisieren.
Aktualisieren Sie eine Tabelle mit einem Partitionsschlüssel
Sie können die folgenden Codefragmente verwenden, um eine Tabelle mit einem Partitionsschlüssel zu aktualisieren.
- Java
-
public void updateTableCompositePartitionKeyEnforcement() {
System.out.println("Updating table");
UpdateTableRequest updateTableRequest = new UpdateTableRequest();
updateTableRequest.setDatabaseName(DATABASE_NAME);
updateTableRequest.setTableName(TABLE_NAME);
// Can update enforcement level for dimension type partition key with OPTIONAL or REQUIRED enforcement
final List<PartitionKey> partitionKeyWithDimensionAndRequiredEnforcement = Collections.singletonList(new PartitionKey()
.withName(COMPOSITE_PARTITION_KEY_DIM_NAME)
.withType(PartitionKeyType.DIMENSION)
.withEnforcementInRecord(PartitionKeyEnforcementLevel.REQUIRED));
Schema schema = new Schema();
schema.setCompositePartitionKey(partitionKeyWithDimensionAndRequiredEnforcement);
updateTableRequest.withSchema(schema);
writeClient.updateTable(updateTableRequest);
System.out.println("Table updated");
- Java v2
-
public void updateTableCompositePartitionKeyEnforcement() {
System.out.println("Updating table");
// Can update enforcement level for dimension type partition key with OPTIONAL or REQUIRED enforcement
final List<PartitionKey> partitionKeyWithDimensionAndRequiredEnforcement = Collections.singletonList(PartitionKey
.builder()
.name(COMPOSITE_PARTITION_KEY_DIM_NAME)
.type(PartitionKeyType.DIMENSION)
.enforcementInRecord(PartitionKeyEnforcementLevel.REQUIRED)
.build());
final Schema schema = Schema.builder()
.compositePartitionKey(partitionKeyWithDimensionAndRequiredEnforcement).build();
final UpdateTableRequest updateTableRequest = UpdateTableRequest.builder()
.databaseName(DATABASE_NAME).tableName(TABLE_NAME).schema(schema).build();
writeClient.updateTable(updateTableRequest);
System.out.println("Table updated");
- Go v1
-
// Update table partition key enforcement attribute
updateTableInput := ×treamwrite.UpdateTableInput{
DatabaseName: aws.String(*databaseName),
TableName: aws.String(*tableName),
// Can update enforcement level for dimension type partition key with OPTIONAL or REQUIRED enforcement
Schema: ×treamwrite.Schema{
CompositePartitionKey: []*timestreamwrite.PartitionKey{
{
Name: aws.String(CompositePartitionKeyDimName),
EnforcementInRecord: aws.String("REQUIRED"),
Type: aws.String("DIMENSION"),
},
}},
}
updateTableOutput, err := writeSvc.UpdateTable(updateTableInput)
if err != nil {
fmt.Println("Error:")
fmt.Println(err)
} else {
fmt.Println("Update table is successful, below is the output:")
fmt.Println(updateTableOutput)
}
- Go v2
-
// Update table partition key enforcement attribute
updateTableInput := ×treamwrite.UpdateTableInput{
DatabaseName: aws.String(*databaseName),
TableName: aws.String(*tableName),
// Can update enforcement level for dimension type partition key with OPTIONAL or REQUIRED enforcement
Schema: &types.Schema{
CompositePartitionKey: []types.PartitionKey{
{
Name: aws.String(CompositePartitionKeyDimName),
EnforcementInRecord: types.PartitionKeyEnforcementLevelRequired,
Type: types.PartitionKeyTypeDimension,
},
}},
}
updateTableOutput, err := timestreamBuilder.WriteSvc.UpdateTable(context.TODO(), updateTableInput)
if err != nil {
fmt.Println("Error:")
fmt.Println(err)
} else {
fmt.Println("Update table is successful, below is the output:")
fmt.Println(updateTableOutput)
}
- Python
-
def update_table(self):
print('Updating table')
try:
# Can update enforcement level for dimension type partition key with OPTIONAL or REQUIRED enforcement
partition_key_with_dimension_and_required_enforcement = [
{
'Type': 'DIMENSION',
'Name': COMPOSITE_PARTITION_KEY_DIM_NAME,
'EnforcementInRecord': 'REQUIRED'
}
]
schema = {
'CompositePartitionKey': partition_key_with_dimension_and_required_enforcement
}
self.client.update_table(DatabaseName=DATABASE_NAME, TableName=TABLE_NAME,
Schema=schema)
print('Table updated.')
except Exception as err:
print('Update table failed:', err)