$fill

  • Si applica a: ✅ Azure DocumentDB

La fase $fill viene usata per riempire i valori mancanti o Null nei documenti all'interno della pipeline di aggregazione. Fornisce vari metodi per popolare i dati mancanti, tra cui l'uso di valori statici, interpolazione lineare o valori dei documenti precedenti/successivi.

Sintassi

{
  $fill: {
    sortBy: <sort specification>,
    partitionBy: <partition fields>,
    partitionByFields: <array of partition field names>,
    output: {
      <field1>: { value: <expression> },
      <field2>: { method: <string> }
    }
  }
}

Parametri

Parametro Description
sortBy Specifica l'ordinamento per i documenti quando si applicano metodi di riempimento che dipendono dall'ordine dei documenti.
partitionBy Optional. Raggruppa i documenti in partizioni. Le operazioni di riempimento vengono applicate separatamente all'interno di ogni partizione.
partitionByFields Optional. Sintassi alternativa per partitionBy usando una matrice di nomi di campo.
output Specifica i campi da compilare e il metodo o il valore da utilizzare per compilare i dati mancanti.

Metodi Fill

Metodo Description
value Compilare con un valore statico o un risultato dell'espressione specificato.
linear Compilare usando l'interpolazione lineare tra valori noti (solo campi numerici).
locf Ultima osservazione portata avanti: usare l'ultimo valore noto.
linear Interpolazione lineare tra i valori circostanti.

Esempi

Si consideri questo documento di esempio dalla raccolta negozi.

{
  "_id": "2cf3f885-9962-4b67-a172-aa9039e9ae2f",
  "name": "First Up Consultants | Bed and Bath Center - South Amir",
  "location": {
    "lat": 60.7954,
    "lon": -142.0012
  },
  "staff": {
    "totalStaff": {
      "fullTime": 18,
      "partTime": 17
    }
  },
  "sales": {
    "totalSales": 37701,
    "salesByCategory": [
      {
        "categoryName": "Mattress Toppers",
        "totalSales": 37701
      }
    ]
  },
  "promotionEvents": [
    {
      "eventName": "Price Drop Palooza",
      "promotionalDates": {
        "startDate": {
          "Year": 2024,
          "Month": 9,
          "Day": 21
        },
        "endDate": {
          "Year": 2024,
          "Month": 9,
          "Day": 30
        }
      },
      "discounts": [
        {
          "categoryName": "Bath Accessories",
          "discountPercentage": 18
        },
        {
          "categoryName": "Pillow Top Mattresses",
          "discountPercentage": 17
        }
      ]
    }
  ]
}

Esempio 1: Riempire i valori mancanti con valore statico

Questa query riempie i valori mancanti totalSales nella salesByCategory matrice con un valore predefinito pari a 0.

db.stores.aggregate([{
    $match: {
        company: {
            $in: ["First Up Consultants"]
        }
    }
}, {
    $unwind: "$sales.salesByCategory"
}, {
    $fill: {
        output: {
            "sales.salesByCategory.totalSales": {
                value: 0
            }
        }
    }
}, {
    $group: {
        _id: "$_id",
        name: {
            $first: "$name"
        },
        salesByCategory: {
            $push: "$sales.salesByCategory"
        }
    }
}])

I primi due risultati restituiti da questa query sono:

[
    {
        "_id": "affdc09c-7356-4fff-a857-e8301f57159c",
        "name": "First Up Consultants | Sports Gear Pantry - Wildermanhaven",
        "salesByCategory": [
            {
                "categoryName": "Baseball Gear",
                "totalSales": 33878
            },
            {
                "categoryName": "Volleyball Gear",
                "totalSales": 34031
            }
        ]
    },
    {
        "_id": "1cf667b4-d8ce-4f1a-bad1-a1f0bbce26c2",
        "name": "First Up Consultants | Picture Frame Variety - New Abrahamborough",
        "salesByCategory": [
            {
                "categoryName": "Picture Hanging Supplies",
                "totalSales": 7229
            },
            {
                "categoryName": "Collage Frames",
                "totalSales": 40014
            }
        ]
    }
]

Esempio 2: Compilare i dati mancanti del personale usando l'ultima osservazione portata avanti

Questa query riempie i dati del personale part-time mancanti usando l'ultimo valore noto all'interno di ogni gruppo di archivi.

db.stores.aggregate([{
    $fill: {
        sortBy: {
            "_id": 1
        },
        output: {
            "staff.totalStaff.partTime": {
                method: "locf"
            }
        }
    }
}, {
    $project: {
        name: 1,
        "staff.totalStaff": 1
    }
}])

I primi due risultati restituiti da questa query sono:

[
    {
        "_id": "00003278-4226-4ca7-871d-e80d8f414431",
        "name": "Wide World Importers | Camera Depot - Lake Luramouth",
        "staff": {
            "totalStaff": {
                "fullTime": 20,
                "partTime": 6
            }
        }
    },
    {
        "_id": "00009bd0-c44e-4cc8-ab03-347076d74a1a",
        "name": "Wide World Importers | Music Stop - Rebeccaside",
        "staff": {
            "totalStaff": {
                "fullTime": 9,
                "partTime": 0
            }
        }
    }
]

Esempio 3: Riempire le percentuali di sconto mancanti con un valore medio

Questa query riempie le percentuali di sconto mancanti con la percentuale di sconto media in tutti i negozi.

db.stores.aggregate([
  { $unwind: "$promotionEvents" },
  { $unwind: "$promotionEvents.discounts" },
  {
    $fill: {
      partitionBy: "$promotionEvents.eventName",
      sortBy: { "promotionEvents.discounts.categoryName": 1 },
      output: {
        "promotionEvents.discounts.discountPercentage": { 
          value: { $avg: "$promotionEvents.discounts.discountPercentage" } 
        }
      }
    }
  },
  {
    $group: {
      _id: { storeId: "$_id", eventName: "$promotionEvents.eventName" },
      storeName: { $first: "$name" },
      eventName: { $first: "$promotionEvents.eventName" },
      discounts: { $push: "$promotionEvents.discounts" }
    }
  }
])

I primi due risultati restituiti da questa query sono:

[
    {
        "_id": {
            "storeId": "70d4cc90-23b1-46e3-8f59-630648e311a4",
            "eventName": "Price Slash Spectacular"
        },
        "storeName": "Wide World Importers | Music Bazaar - West Johnpaulhaven",
        "eventName": "Price Slash Spectacular",
        "discounts": [
            {
                "categoryName": "CDs",
                "discountPercentage": 22
            },
            {
                "categoryName": "Vinyl Records",
                "discountPercentage": 21
            }
        ]
    },
    {
        "_id": {
            "storeId": "24873ac4-b2d1-4216-a425-3375a384b23d",
            "eventName": "Massive Deal Mania"
        },
        "storeName": "Northwind Traders | Furniture Pantry - Farrellchester",
        "eventName": "Massive Deal Mania",
        "discounts": [
            {
                "categoryName": "Bookcases",
                "discountPercentage": 22
            },
            {
                "categoryName": "Cabinets",
                "discountPercentage": 8
            }
        ]
    }
]

Casi d'uso

  • Pulizia dei dati: compilare i valori mancanti nei set di dati importati
  • Dati delle serie temporali: gestire le lacune nei dati sequenziali usando l'interpolazione
  • Valori predefiniti: Assegnare valori predefiniti ai campi facoltativi
  • Normalizzazione dei dati: garantire una struttura dei dati coerente tra documenti
  • Last updated on