load_new_data: Chargement de nouvelles données

In signaux-faibles/rsignauxfaibles: Charge et Analyse les Données de Signaux Faibles

Description

Chargement de nouvelles données

Loads new data

Usage

## S3 method for class 'sf_task'
load_new_data(
  task,
  periods,
  batch = "latest",
  database = task[["database"]],
  collection = task[["collection"]],
  mongodb_uri = task[["mongodb_uri"]],
  fields = get_fields(training = FALSE),
  min_effectif = 10L,
  rollback_months = 1L,
  database_query_fun = query_mongodb,
  ...
)

load_new_data(task, ...)

Arguments

task	[sf_task] Objet s3 de type sf_task
periods	[Date()] Périodes d'intérêt, auquels charger les données. Des périodes supplémentairs peuvent être chargées selon la valeur de rollback_months.
batch	character(1) Batch auquel doit être importées les données. Les modifications opérées par les batchs ultérieurs sont ignorées.
database	character(1) Nom de la base de données vers laquelle param exporter. Par défaut, celle stockée dans task.
collection	character(1) Nom de la collection vers laquelle exporter. Par défaut, celle stockée dans task.
mongodb_uri	character(1) url to the database in mongodb uri format.
fields	character() Noms des champs à requêter dans la base de données. Doit contenir "siret" et "periode". Si égal à NULL, alors charge tous les champs disponibles.
min_effectif	integer(1) Limite basse du filtrage de l'effectif (la limite est incluse)
rollback_months	integer(1) Nombre de mois précédant le premier mois de periods à charger. Permet d'effectuer des calculs de différences ou de moyennes glissantes pour les périodes d'intérêt.
database_query_fun	function Une fonction de requête à la base, qui permet notamment de simuler la requête dans le cadre des tests. Utiliser la fonction par défaut pour requêter la base mongodb en production.
...	Additional parameters depending on class of task

Value

[sf_task]
L'objet task donné en entrée auquel le champs "new_data" a été ajouté (ou écrasé), contenant un data.frame() avec les colonnes incluses dans le paramètre d'entrée fields, et pour chaque ligne un couple unique siret x periode.

Methods (by class)

• sf_task:

signaux-faibles/rsignauxfaibles documentation built on Dec. 2, 2020, 3:24 a.m.