Descrição
Retorna uma amostra não determinista dos resultados da etapa anterior.
Há dois modos disponíveis:
- O modo
DOCUMENTSpermite a amostragem de um número definido de documentos.- Esse modo é semelhante a
GoogleSQL.RESERVOIRporque gera uma amostra de tamanhon, em que qualquer amostra de tamanhoné igualmente possível.
- Esse modo é semelhante a
- O modo
PERCENTpermite a amostragem de uma porcentagem de documentos- Esse modo é semelhante a
GoogleSQL.BERNOULLIporque cada documento é selecionado de forma independente com uma probabilidadepercentigual. Isso resulta em#documents * percent / 100documentos retornados em média.
- Esse modo é semelhante a
Sintaxe
Node.js
const sampled = await db.pipeline()
.database()
.sample(50)
.execute();
const sampled = await db.pipeline()
.database()
.sample({ percent: 0.5 })
.execute();
Comportamento
Modo documentos
O modo de documentos recupera um número especificado de documentos em ordem aleatória.
O número especificado precisa ser um valor INT64 não negativo.
Por exemplo, para a seguinte coleção:
Node.js
await db.collection('cities').doc('SF').set({name: 'San Francsico', state: 'California'});
await db.collection('cities').doc('NYC').set({name: 'New York City', state: 'New York'});
await db.collection('cities').doc('CHI').set({name: 'Chicago', state: 'Illinois'});
A etapa de amostragem no modo de documento pode ser usada para recuperar um subconjunto não determinista de resultados dessa coleção.
Node.js
const sampled = await db.pipeline()
.collection("/cities")
.sample(1)
.execute();
Neste exemplo, apenas um documento aleatório seria retornado.
{name: 'New York City', state: 'New York'}
Se o número fornecido for maior que o número total de documentos retornados, todos os documentos serão retornados em ordem aleatória.
Node.js
const sampled = await db.pipeline()
.collection("/cities")
.sample(5)
.execute();
Isso vai gerar os seguintes documentos:
{name: 'New York City', state: 'New York'}
{name: 'Chicago', state: 'Illinois'}
{name: 'San Francisco', state: 'California'}
Exemplos de clientes
Web
let results; // Get a sample of 100 documents in a database results = await execute(db.pipeline() .database() .sample(100) ); // Randomly shuffle a list of 3 documents results = await execute(db.pipeline() .documents([ doc(db, "cities", "SF"), doc(db, "cities", "NY"), doc(db, "cities", "DC"), ]) .sample(3) );
Swift
var results: Pipeline.Snapshot // Get a sample of 100 documents in a database results = try await db.pipeline() .database() .sample(count: 100) .execute() // Randomly shuffle a list of 3 documents results = try await db.pipeline() .documents([ db.collection("cities").document("SF"), db.collection("cities").document("NY"), db.collection("cities").document("DC"), ]) .sample(count: 3) .execute()
Kotlin
var results: Task<Pipeline.Snapshot> // Get a sample of 100 documents in a database results = db.pipeline() .database() .sample(100) .execute() // Randomly shuffle a list of 3 documents results = db.pipeline() .documents( db.collection("cities").document("SF"), db.collection("cities").document("NY"), db.collection("cities").document("DC") ) .sample(3) .execute()
Java
Task<Pipeline.Snapshot> results; // Get a sample of 100 documents in a database results = db.pipeline() .database() .sample(100) .execute(); // Randomly shuffle a list of 3 documents results = db.pipeline() .documents( db.collection("cities").document("SF"), db.collection("cities").document("NY"), db.collection("cities").document("DC") ) .sample(3) .execute();
Python
# Get a sample of 100 documents in a database results = client.pipeline().database().sample(100).execute() # Randomly shuffle a list of 3 documents results = ( client.pipeline() .documents( client.collection("cities").document("SF"), client.collection("cities").document("NY"), client.collection("cities").document("DC"), ) .sample(3) .execute() )
Java
// Get a sample of 100 documents in a database Pipeline.Snapshot results1 = firestore.pipeline().database().sample(100).execute().get(); // Randomly shuffle a list of 3 documents Pipeline.Snapshot results2 = firestore .pipeline() .documents( firestore.collection("cities").document("SF"), firestore.collection("cities").document("NY"), firestore.collection("cities").document("DC")) .sample(3) .execute() .get();
Modo porcentagem
No modo de porcentagem, cada documento tem uma chance especificada de percent de ser retornado. Ao contrário do modo de documentos, a ordem aqui não é aleatória e preserva a ordem preexistente dos documentos. Essa entrada de porcentagem precisa ser um valor duplo entre 0.0 e 1.0.
Como cada documento é selecionado de forma independente, a saída não é determinista e, em média, #documents * percent / 100 documentos serão retornados.
Por exemplo, para a seguinte coleção:
Node.js
await db.collection('cities').doc('SF').set({name: 'San Francsico', state: 'California'});
await db.collection('cities').doc('NYC').set({name: 'New York City', state: 'New York'});
await db.collection('cities').doc('CHI').set({name: 'Chicago', state: 'Illinois'});
await db.collection('cities').doc('ATL').set({name: 'Atlanta', state: 'Georgia'});
A etapa de amostragem no modo de porcentagem pode ser usada para recuperar (em média) 50% dos documentos da etapa de coleta.
Node.js
const sampled = await db.pipeline()
.collection("/cities")
.sample({ percent: 0.5 })
.execute();
Isso vai resultar em uma amostra não determinista de (em média) 50% dos documentos da coleção cities. Confira uma saída possível.
{name: 'New York City', state: 'New York'}
{name: 'Chicago', state: 'Illinois'}
No modo de porcentagem, como cada documento tem a mesma probabilidade de ser selecionado, é possível que nenhum ou todos os documentos sejam retornados.
Exemplos de clientes
Web
// Get a sample of on average 50% of the documents in the database const results = await execute(db.pipeline() .database() .sample({ percentage: 0.5 }) );
Swift
// Get a sample of on average 50% of the documents in the database let results = try await db.pipeline() .database() .sample(percentage: 0.5) .execute()
Kotlin
// Get a sample of on average 50% of the documents in the database val results = db.pipeline() .database() .sample(SampleStage.withPercentage(0.5)) .execute()
Java
// Get a sample of on average 50% of the documents in the database Task<Pipeline.Snapshot> results = db.pipeline() .database() .sample(SampleStage.withPercentage(0.5)) .execute();
Python
from google.cloud.firestore_v1.pipeline_stages import SampleOptions # Get a sample of on average 50% of the documents in the database results = ( client.pipeline().database().sample(SampleOptions.percentage(0.5)).execute() )
Java
// Get a sample of on average 50% of the documents in the database Pipeline.Snapshot results = firestore.pipeline().database().sample(Sample.withPercentage(0.5)).execute().get();