Trabajar con índices secundarios globales: .NET
Puede utilizar la API de bajo nivel AWS SDK for .NET para crear una tabla Amazon DynamoDB con uno o varios índices secundarios globales, describir los índices de la tabla y utilizarlos para realizar consultas. Estas operaciones se mapean a las operaciones correspondientes de DynamoDB. Para obtener más información, consulte la Referencia de la API de Amazon DynamoDB.
A continuación se indican los pasos comunes para las operaciones con tablas mediante el API de bajo nivel de .NET.
-
Cree una instancia de la clase
AmazonDynamoDBClient
. -
Cree los objetos de solicitud correspondientes para proporcionar los parámetros obligatorios y opcionales de la operación.
Por ejemplo, cree un objeto
CreateTableRequest
para crear una tabla y un objetoQueryRequest
para consultar una tabla o un índice. -
Ejecute el método apropiado proporcionado por el cliente que ha creado en el paso anterior.
Temas
Creación de una tabla con un índice secundario global
Puede crear índices secundarios globales a la vez que crea la tabla. Para ello, utilice CreateTable
e indique las especificaciones para uno o varios índices secundarios globales. En el ejemplo de código C# siguiente, se crea una tabla para contener información sobre datos meteorológicos. La clave de partición es Location
y la de ordenación, Date
. Un índice secundario global denominado PrecipIndex
permite obtener acceso rápido a los datos sobre precipitaciones de varias ubicaciones.
A continuación se indican los pasos que hay que seguir para crear una tabla con un índice secundario global mediante el API de bajo nivel de .NET.
-
Cree una instancia de la clase
AmazonDynamoDBClient
. -
Cree una instancia de la clase
CreateTableRequest
para proporcionar la información de solicitud.Debe proporcionar el nombre de la tabla, su clave principal y los valores de rendimiento aprovisionado. Para el índice secundario global, debe proporcionar el nombre del índice, los ajustes de rendimiento aprovisionado, las definiciones de atributos de la clave de ordenación del índice, el esquema de claves del índice y la proyección de atributos.
-
Ejecute el método
CreateTable
proporcionando el objeto de solicitud como parámetro.
En el siguiente ejemplo de código C# se ponen en práctica los pasos anteriores. El código crea una tabla (WeatherData
) con un índice secundario global (PrecipIndex
). La clave de partición del índice es Date
y la de ordenación, Precipitation
. Todos los atributos de la tabla se proyectan en el índice. Los usuarios pueden consultar este índice para obtener los datos meteorológicos de una determinada fecha y, si lo desean, ordenarlos según la cantidad de precipitación.
Ya que Precipitation
no es un atributo de clave para la tabla, no es obligatorio. Sin embargo, los elementosWeatherData
sin Precipitation
no aparecen en PrecipIndex
.
client = new AmazonDynamoDBClient(); string tableName = "WeatherData"; // Attribute definitions var attributeDefinitions = new List<AttributeDefinition>() { {new AttributeDefinition{ AttributeName = "Location", AttributeType = "S"}}, {new AttributeDefinition{ AttributeName = "Date", AttributeType = "S"}}, {new AttributeDefinition(){ AttributeName = "Precipitation", AttributeType = "N"} } }; // Table key schema var tableKeySchema = new List<KeySchemaElement>() { {new KeySchemaElement { AttributeName = "Location", KeyType = "HASH"}}, //Partition key {new KeySchemaElement { AttributeName = "Date", KeyType = "RANGE"} //Sort key } }; // PrecipIndex var precipIndex = new GlobalSecondaryIndex { IndexName = "PrecipIndex", ProvisionedThroughput = new ProvisionedThroughput { ReadCapacityUnits = (long)10, WriteCapacityUnits = (long)1 }, Projection = new Projection { ProjectionType = "ALL" } }; var indexKeySchema = new List<KeySchemaElement> { {new KeySchemaElement { AttributeName = "Date", KeyType = "HASH"}}, //Partition key {new KeySchemaElement{AttributeName = "Precipitation",KeyType = "RANGE"}} //Sort key }; precipIndex.KeySchema = indexKeySchema; CreateTableRequest createTableRequest = new CreateTableRequest { TableName = tableName, ProvisionedThroughput = new ProvisionedThroughput { ReadCapacityUnits = (long)5, WriteCapacityUnits = (long)1 }, AttributeDefinitions = attributeDefinitions, KeySchema = tableKeySchema, GlobalSecondaryIndexes = { precipIndex } }; CreateTableResponse response = client.CreateTable(createTableRequest); Console.WriteLine(response.CreateTableResult.TableDescription.TableName); Console.WriteLine(response.CreateTableResult.TableDescription.TableStatus);
Debe esperar hasta que DynamoDB cree la tabla y establezca el estado de esta última en ACTIVE
. A partir de ese momento, puede comenzar a incluir elementos de datos en la tabla.
Descripción de una tabla con un índice secundario global
Para obtener información sobre los índices secundarios globales en una tabla, use DescribeTable
. Para cada índice, puede obtener acceso a su nombre, esquema de claves y atributos proyectados.
A continuación se indican los pasos que hay que seguir para acceder a la información de un índice secundario global de una tabla mediante el API de bajo nivel de .NET.
-
Cree una instancia de la clase
AmazonDynamoDBClient
. -
Ejecute el método
describeTable
proporcionando el objeto de solicitud como parámetro.Cree una instancia de la clase
DescribeTableRequest
para proporcionar la información de solicitud. Debe proporcionar el nombre de la tabla.
En el siguiente ejemplo de código C# se ponen en práctica los pasos anteriores.
ejemplo
client = new AmazonDynamoDBClient(); string tableName = "WeatherData"; DescribeTableResponse response = client.DescribeTable(new DescribeTableRequest { TableName = tableName}); List<GlobalSecondaryIndexDescription> globalSecondaryIndexes = response.DescribeTableResult.Table.GlobalSecondaryIndexes; // This code snippet will work for multiple indexes, even though // there is only one index in this example. foreach (GlobalSecondaryIndexDescription gsiDescription in globalSecondaryIndexes) { Console.WriteLine("Info for index " + gsiDescription.IndexName + ":"); foreach (KeySchemaElement kse in gsiDescription.KeySchema) { Console.WriteLine("\t" + kse.AttributeName + ": key type is " + kse.KeyType); } Projection projection = gsiDescription.Projection; Console.WriteLine("\tThe projection type is: " + projection.ProjectionType); if (projection.ProjectionType.ToString().Equals("INCLUDE")) { Console.WriteLine("\t\tThe non-key projected attributes are: " + projection.NonKeyAttributes); } }
Consulta de un índice secundario local
Puede utilizar Query
en un índice secundario global, de un modo bastante similar al que realiza una Query
en una tabla. Debe especificar el nombre del índice, los criterios de consulta de la clave de partición y la clave de ordenación (si procede) del índice y los atributos que desea devolver. En este ejemplo, el índice es PrecipIndex
, cuyas clave de partición y ordenación son, respectivamente, Date
y Precipitation
. La consulta del índice devuelve todos los datos meteorológicos de una determinada fecha cuando el valor de Precipitation sea mayor que cero.
A continuación se indican los pasos que hay que seguir para consultar un índice secundario global mediante el API de bajo nivel de .NET.
-
Cree una instancia de la clase
AmazonDynamoDBClient
. -
Cree una instancia de la clase
QueryRequest
para proporcionar la información de solicitud. -
Ejecute el método
query
proporcionando el objeto de solicitud como parámetro.
El nombre de atributo Date
es una palabra reservada de DynamoDB. Por consiguiente, debe usar un nombre de atributo de expresión como marcador de posición en la expresión KeyConditionExpression
.
En el siguiente ejemplo de código C# se ponen en práctica los pasos anteriores.
ejemplo
client = new AmazonDynamoDBClient(); QueryRequest queryRequest = new QueryRequest { TableName = "WeatherData", IndexName = "PrecipIndex", KeyConditionExpression = "#dt = :v_date and Precipitation > :v_precip", ExpressionAttributeNames = new Dictionary<String, String> { {"#dt", "Date"} }, ExpressionAttributeValues = new Dictionary<string, AttributeValue> { {":v_date", new AttributeValue { S = "2013-08-01" }}, {":v_precip", new AttributeValue { N = "0" }} }, ScanIndexForward = true }; var result = client.Query(queryRequest); var items = result.Items; foreach (var currentItem in items) { foreach (string attr in currentItem.Keys) { Console.Write(attr + "---> "); if (attr == "Precipitation") { Console.WriteLine(currentItem[attr].N); } else { Console.WriteLine(currentItem[attr].S); } } Console.WriteLine(); }