Esta página descreve como calcular a latência da solicitação da API Spanner de streaming e de solicitações de partição.
É possível calcular o streaming e a solicitação de partição da API Spanner
latências com os campos no objeto struct metadata
de uma
AuditLog
. Os metadados são do tipo QueryPerformanceMetadata
.
Para solicitações de streaming e partição, o metadata
não contém um campo processingSecondsDuration
. Para saber como usar o
processingSecondsDuration
para calcular latências de solicitação para todos os outros
tipos de solicitação, consulte Duração do processamento.
Latências de solicitações para solicitações de streaming
Quando um cliente envia uma solicitação de streaming e, à medida que a API Spanner retorna conjuntos de resultados parciais, Os Registros de auditoria do Cloud gravam registros de auditoria do primeiro e do último de resposta. A latência de uma solicitação de streaming é o tempo decorrido entre o momento em que a API Spanner recebe a solicitação e recebe a última resposta.
Reconhecer entradas de registro de auditoria de solicitações de streaming
Para calcular a latência de uma solicitação de streaming, é necessário identificar
as entradas de registro relacionadas à solicitação. As entradas de registro têm o
protoPayload.methodName
definido como
google.spanner.v1.Spanner.ExecuteStreamingSql
ou
google.spanner.v1.Spanner.StreamingRead
. Para cada solicitação de streaming, há
duas entradas de registro, agrupadas por operation.id
. A primeira entrada tem
operation.first
definido como true
, e a última tem operation.last
definido como
true
. O objeto protoPayload.metadata.responseTimestamp
também é preenchido.
Calcular a latência de solicitações de streaming
Para calcular a latência de uma solicitação de streaming, filtre os registros de auditoria
por operation.id
. A diferença entre os registros
protoPayload.metadata.responseTimestamp
e os primeiros
protoPayload.requestMetadata.requestAttributes.time
é a latência da solicitação.
Exemplos de registros de auditoria para solicitações de streaming
Para encontrar todas as entradas de registro de uma solicitação de streaming, execute a seguinte consulta no Análise de registros, substituindo OPERATION_ID com o valor pretendido:
operation.id="OPERATION_ID"
O exemplo a seguir encontra entradas de registro para uma solicitação de streaming com o
operation.id
de 15327696495839874591
:
operation.id="15327696495839874591"
Primeiro registro retornado
{
"protoPayload": {
"@type": "type.googleapis.com/google.cloud.audit.AuditLog",
"authenticationInfo": {...},
"requestMetadata": {
"requestAttributes": {
"time": "2023-02-27T16:57:40.552952297Z",
},
"destinationAttributes": {}
},
"serviceName": "spanner.googleapis.com",
"methodName": "google.spanner.v1.Spanner.ExecuteStreamingSql",
"authorizationInfo": [{...}],
"resourceName": "projects/example-project/instances/example-instance/databases/example-database/sessions/example-session",
"request": {
"session": "projects/example-project/instances/example-instance/databases/example-database/sessions/example-session",
"requestOptions": {},
"sql": "SELECT COUNT(*) as count FROM Example_table WHERE Example_Column > @timestamp",
"@type": "type.googleapis.com/google.spanner.v1.ExecuteSqlRequest",
"queryOptions": {}
},
"metadata": {
"@type": "type.googleapis.com/spanner.cloud.instance_v1.QueryPerformanceMetadata",
"responseTimestamp": "2023-02-27T16:57:40.555730699Z"
}
},
"insertId": "h7fj0jei6597",
"resource": {...},
"timestamp": "2023-02-27T16:57:40.552391554Z",
"severity": "INFO",
"logName": "projects/example-project/logs/cloudaudit.googleapis.com%2Fdata_access",
"operation": {
"id": "15327696495839874591",
"producer": "spanner.googleapis.com",
"first": true
},
"receiveTimestamp": "2023-02-27T16:57:41.507770020Z"
}
Último registro retornado
{
"protoPayload": {
"@type": "type.googleapis.com/google.cloud.audit.AuditLog",
"authenticationInfo": {...},
"requestMetadata": {
"requestAttributes": {
"time": "2023-02-27T16:57:40.552952297Z",
},
"destinationAttributes": {}
},
"serviceName": "spanner.googleapis.com",
"methodName": "google.spanner.v1.Spanner.ExecuteStreamingSql",
"authorizationInfo": [{...}],
"resourceName": "projects/example-project/instances/example-instance/databases/example-database/sessions/example-session",
"metadata": {
"responseTimestamp": "2023-02-27T16:57:40.556138125Z",
"@type": "type.googleapis.com/spanner.cloud.instance_v1.QueryPerformanceMetadata"
}
},
"insertId": "h7fj0jei6598",
"resource": {...},
"timestamp": "2023-02-27T16:57:40.552391554Z",
"severity": "INFO",
"logName": "projects/example-project/logs/cloudaudit.googleapis.com%2Fdata_access",
"operation": {
"id": "15327696495839874591",
"producer": "spanner.googleapis.com",
"last": true
},
"receiveTimestamp": "2023-02-27T16:57:41.507770020Z"
}
A latência da solicitação é a metadata.responseTimestamp
mais recente menos a
requestAttributes.time
mais antiga. O resultado é
2023-02-27T16:57:40.556138125Z-2023-02 - 2023-02-27T16:57:40.552952297Z, que
corresponde a 0,003185828 segundos.
Latências de solicitações de partição
Quando um cliente envia uma solicitação particionada, o Spanner cria várias ou de sistemas operacionais de contêineres. Calcular a latência de uma solicitação de partição de ponta a ponta e chamadas subsequentes para as partições, identifique os registros de auditoria associados à solicitação principal.
Reconhecer entradas de registro de auditoria de solicitações de partição
Quando você faz uma solicitação PartitionRead
ou PartitionQuery
, um conjunto de
partições é retornado no
PartitionResponse
. À medida que você
faz chamadas Read
, ExecuteSql
ou ExecuteStreaming
, respectivamente, para cada
partição, o Spanner registra registros de auditoria para esses métodos. Cada um
deles contém um identificador para agrupar os registros, chamado
protoPayload.metadata.partitionBatchIdentifier
. O
O objeto protoPayload.metadata.responseTimestamp
também é preenchido.
Calcular a latência da solicitação para solicitações de partição
Para calcular a latência de uma solicitação de partição, filtre os
registros de auditoria por metadata.partitionBatchIdentifier
. A diferença entre a
metadata.responseTimestamp
mais recente e a
protoPayload.requestMetadata.requestAttributes.time
mais antiga é a latência da solicitação.
Exemplos de registros de auditoria para solicitações de partição
Para encontrar todas as entradas de registro de uma solicitação de partição, execute a seguinte consulta no Explorador de registros, substituindo a variável PARTITION_BATCH_ID pelo valor desejado:
metadata.partitionBatchIdentifier="PARTITION_BATCH_ID"
O exemplo a seguir encontra entradas de registro para uma solicitação de partição com o
metadata.partitionBatchIdentifier
de 15327696495839874591
:
metadata.partitionBatchIdentifier="15327696495839874591"
Primeiro registro retornado
{
"protoPayload": {
"@type": "type.googleapis.com/google.cloud.audit.AuditLog",
"authenticationInfo": {...},
"requestMetadata": {
"requestAttributes": {
"time": "2023-02-15T18:13:39.341584693Z",
},
},
"serviceName": "spanner.googleapis.com",
"methodName": "google.spanner.v1.Spanner.ExecuteStreamingSql",
"authorizationInfo": [{...}],
"resourceName": "projects/example-project/instances/example-instance/databases/example-db/sessions/example-session",
"request": {...},
"metadata": {
"@type": "type.googleapis.com/spanner.cloud.instance_v1.QueryPerformanceMetadata",
"partitionBatchIdentifier": "4841471066190013455",
"responseTimestamp": "2023-02-15T18:13:39.343693061Z"
}
},
"insertId": "4fug42dqke5",
"resource": {...},
"timestamp": "2023-02-15T18:13:39.341069413Z",
"severity": "INFO",
"logName": "projects/example-project/logs/cloudaudit.googleapis.com%2Fdata_access",
"operation": {...},
"receiveTimestamp": "2023-02-15T18:13:39.983812511Z"
}
Segundo registro retornado
{
"protoPayload": {
"@type": "type.googleapis.com/google.cloud.audit.AuditLog",
"authenticationInfo": {...},
"requestMetadata": {
"requestAttributes": {
"time": "2023-02-15T18:13:39.341584693Z",
},
},
"serviceName": "spanner.googleapis.com",
"methodName": "google.spanner.v1.Spanner.ExecuteStreamingSql",
"authorizationInfo": [{...}],
"resourceName": "projects/example-project/instances/example-instance/databases/example-db/sessions/example-session",
"metadata": {
"responseTimestamp": "2023-02-15T18:13:39.344256101Z",
"partitionBatchIdentifier": "4841471066190013455",
"@type": "type.googleapis.com/spanner.cloud.instance_v1.QueryPerformanceMetadata"
}
},
"insertId": "4fug42dqke6",
"resource": {...},
"timestamp": "2023-02-15T18:13:39.341069413Z",
"severity": "INFO",
"logName": "projects/example-project/logs/cloudaudit.googleapis.com%2Fdata_access",
"operation": {...},
"receiveTimestamp": "2023-02-15T18:13:39.983812511Z"
}
Dependendo do número de partições, o Spanner pode registrar mais registros do que neste exemplo.
Último registro retornado
{
"protoPayload": {
"@type": "type.googleapis.com/google.cloud.audit.AuditLog",
"authenticationInfo": {...},
"requestMetadata": {
"requestAttributes": {
"time": "2023-02-15T18:13:39.439207331Z",
},
},
"serviceName": "spanner.googleapis.com",
"methodName": "google.spanner.v1.Spanner.ExecuteStreamingSql",
"authorizationInfo": [{...}],
"resourceName": "projects/example-project/instances/example-instance/databases/example-db/sessions/example-session",
"metadata": {
"partitionBatchIdentifier": "4841471066190013455",
"@type": "type.googleapis.com/spanner.cloud.instance_v1.QueryPerformanceMetadata",
"responseTimestamp": "2023-02-15T18:13:39.441692339Z"
}
},
"insertId": "4fug42dqkec",
"resource": {...},
"timestamp": "2023-02-15T18:13:39.438607931Z",
"severity": "INFO",
"logName": "projects/example-project/logs/cloudaudit.googleapis.com%2Fdata_access",
"operation": {...},
"receiveTimestamp": "2023-02-15T18:13:39.983812511Z"
}
A latência da solicitação é a metadata.responseTimestamp
mais recente menos a
requestAttributes.time
mais antiga. O resultado é 2023-02-15T18:13:39.441692339Z
- 2023-02-15T18:13:39.341584693Z, o que equivale a 0,100107646 segundos.