Exemplo

Descrição

Retorna uma amostra não determinista dos resultados da etapa anterior.

Há dois modos disponíveis:

  • O modo DOCUMENTS permite a amostragem de um número definido de documentos.
    • Esse modo é semelhante a GoogleSQL.RESERVOIR porque gera uma amostra de tamanho n, em que qualquer amostra de tamanho n é igualmente possível.
  • O modo PERCENT permite a amostragem de uma porcentagem de documentos
    • Esse modo é semelhante a GoogleSQL.BERNOULLI porque cada documento é selecionado de forma independente com uma probabilidade percent igual. Isso resulta em #documents * percent / 100 documentos retornados em média.

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();