Merge Legacy and Ongoing Landings Data
merge_landings.Rd
This function merges preprocessed legacy landings data with ongoing landings data from separate MongoDB collections. It combines the datasets, performs minimal transformations, and uploads the merged result to a new MongoDB collection.
Usage
merge_landings(log_threshold = logger::DEBUG)
Value
This function does not return a value. Instead, it processes the data and uploads the result to a MongoDB collection in the pipeline database.
Details
The function performs the following main operations:
Pulls preprocessed legacy data from the legacy preprocessed MongoDB collection.
Pulls preprocessed ongoing data from the ongoing preprocessed MongoDB collection.
Combines the two datasets using
dplyr::bind_rows()
, adding a 'version' column to distinguish the sources.Selects and orders relevant columns for the final merged dataset.
Uploads the merged data to a new MongoDB collection for merged landings data.