0
253
ViewsConsulta de Dynamodb con GSI y expresión de filtro en columnas que no son de clave de partición y clave de ordenación en nodejs
Tengo un GSI en mi mesa y estoy usando ese GSI para consultar los resultados. Estoy usando una expresión de filtro también
const active_cases = await storesMonthlyAudit(); console.info("actives cases : ", active_cases) async function storesMonthlyAudit() { const params = { TableName: "jms-case-management-dev", IndexName: "entity-sKey-index", ProjectionExpression: "storeId,caseId", KeyConditionExpression: "#entity = :entity", FilterExpression: "#status = :status", ExpressionAttributeNames: { "#entity": "entity", "#status": "status", }, ExpressionAttributeValues: { ":entity": "Case", ":status": "Active" } }; const cases = await Query(params); return cases }Respuesta :
actives cases : { Items: [], Count: 0, ScannedCount: 8012, LastEvaluatedKey: { entity: 'Case', sKey: 'C#10134066', pKey: 'ST#1013' } }Pero cuando probé lo mismo desde la consola de AWS, obtuve el resultado correcto de 2 registros con estado = "Activo"
2 answers
Answer question0
DynamoDB solo accederá a 1 MB de datos por cada solicitud de consulta. Este acceso a datos se cuenta antes que cualquier filtro o expresión de proyección. Parece que tiene más de 1 MB de datos almacenados en la clave de partición especificada. Debe realizar varias solicitudes para acceder a todos los datos.
La consola usó LastEvaluatedKey de la respuesta para realizar consultas adicionales. Puede ver que consumió 559 RCU al ejecutar su consulta, lo que significa que realizó 5 solicitudes en total para que usted encuentre estos dos valores.
También debe realizar varias consultas. Para ello, configure ExclusiveStartKey en solicitudes posteriores, configurando este valor como LastEvaluatedKey de la solicitud anterior. Cuando LastEvaluatedKey no se devuelve de una solicitud, sabe que ha buscado en todos los elementos que coinciden con su consulta.
0
Leí sobre LastEvaluatedKey y ExclusiveStartKey y escribí una pequeña función
async function dbRead(params) { let result = await db.query(params).promise(); let data = result.Items; if (result.LastEvaluatedKey) { params.ExclusiveStartKey = result.LastEvaluatedKey; data = data.concat(await dbRead(params)); } return data; }