RTETransformer : dans le champ d’application

L’API RTETransformer fournit une méthode permettant de transformer et de stocker un tableau de messages en un enregistrement dans l’instance associée ServiceNow en fonction d’une définition ETL (Extract, Transform, and Load) fournie.

Par exemple, vous pouvez utiliser cette API lorsque vous avez une ou des charges utiles JSON qui contiennent des informations utilisateur et que vous souhaitez transformer ces informations en table de sys_user à l’aide du moteur de transformation robuste (RTE).

Utilisez l’espace de noms sn_impex lorsque vous accédez à cette API.

Pour plus d’informations, voir Définir les opérations du moteur de transformation robuste.

RTETransformer : rteTransform(String transformDefinitionId, Boolean verboseLogging, Source de chaîne, Nombre batchSize)

Instancie un objet RTETransformer.

Tableau 1. Paramètres

Nom	Type	Description
transformDefinitionId	Chaîne	Sys_id de la définition d’extraction, de transformation et de chargement (ETL) à utiliser pour la transformation. Pour plus d’informations sur la création d’un ETL, consultez Créer des définitions ETL (Extract Transform Load). Table : définitions ETL [sys_rte_eb_etl_definition]
verboseLogging	Booléen	Marqueur indiquant s’il faut activer la journalisation détaillée et la création de lignes de jeux d’importation pour le débogage. Valeurs valides : true : activer la journalisation et la création de lignes de jeux d’importation. faux : n’activez pas la journalisation et la création de lignes de jeux d’importation.
source	Chaîne	Champ Nom de l’enregistrement du jeu d’importation.
batchSize	Numéro	Nombre de messages à traiter en une seule fois (lot). Par exemple, si une charge utile comporte 10 messages et que cette valeur est définie sur 2, la méthode exécute cinq tâches par lots distinctes pour traiter tous les messages de la charge utile.

L’exemple de code suivant montre comment instancier un objet RTETransformer pour la source testSourceRecord qui a une taille de lot de 10.

(function(/*CTIOperationRequest*/ request, /*CTIOperationResponse*/ response, /*Context*/ ctx) {    
  // Uses an ETL definition with a target table of incident, and mappings for the number and short description field
  var transformer = new sn_impex.RTETransformer("c58f1c6377110110f5455d14cd5a998b", true, "testSourceRecord", 10);
  var messages = ["{\"number\":\"testnumber\",\"short_description\":\"testdesc\"}"];
  var results = transformer.transform(messages);

  for (var i = 0; i < results.length; i++) {
    var dataList = results[i].data.incident;
    gs.log("source record id: " + results[i].sourceRecordSysId);
    gs.log("status: " + results[i].status);
    for (var j = 0; j < dataList.length; j++) {
      gs.log("number:" + dataList[j].number);
      gs.log("short desc:" + dataList[j].short_description);
    }
  }
})(request, response, ctx);

RTETransformer : transform(Message tableau)

Transforme et stocke un tableau de messages en un enregistrement dans l’instance associée ServiceNow en fonction d’une définition ETL (Extract, Transform, and Load) fournie.

Par exemple, si vous souhaitez transformer des informations utilisateur en un enregistrement sys_user, vous pouvez créer un tableau de messages avec un seul message et le transmettre à cette méthode de transformation.

Tableau 2. Paramètres

Nom	Type	Description
message	Tableau d'objets	Objets JSON Stringified représentant les enregistrements à transformer en fonction de la définition ETL. Par exemple, si vous souhaitez transformer un utilisateur unique avec les données actives, l’e-mail, le prénom et le nom de famille en table sys_user, le message ressemblerait à ceci : [ { "active":"true", "email":"[e-mail]", "first_name":"Jane", "last_name":"Doe" } ] Remarque : Les noms de champs doivent correspondre au champ/chemin d’accès des champs de l’entité source.

Tableau 3. Renvoie

Nom	Description
données	Données pour les enregistrements transformés, organisés par nom de table. Les données d’enregistrement renvoyées correspondent aux champs mappés spécifiés dans la définition ETL. Type de données : objet "data": { "tableName": [] }
nom.table de données	Détails de la table contenant les enregistrements. Type de données : tableau d’objets "tableName": [{ "sys_id": String, // Other data for a single transformed record }] } Par exemple : "sys_user": [{ "sys_id":"b29e629877130110f5455d14cd5a99ad", "active": "true", "email": "[e-mail]", "first_name": "Jane", "last_name": "Doe" }]
data.tableName.sys_id	Sys_id de l’enregistrement dans la table. Type de données : chaîne
data.tableName.<other_ETL_info>	Champs supplémentaires qui ont été spécifiés dans l’ETL réussi. Type de données : N’importe lequel
message	Si une erreur se produit lors de la transformation de l’enregistrement spécifié, un message décrivant l’erreur s’affiche. Nul si la transformation réussit. Type de données : chaîne
sourceRecordSysId	Sys_id de l’enregistrement de la table des ensembles d’importation. Le nom de la table d’ensembles d’importations est Récepteur d’événements JSON [imp_json_event_sink]. Type de données : chaîne
statut	État de la transformation, par exemple traité ou erreur. Type de données : chaîne

L’exemple de code suivant montre comment transformer et stocker un enregistrement dans la table Utilisateur [sys_user].

(function(/*CTIOperationRequest*/ request, /*CTIOperationResponse*/ response, /*Context*/ ctx) { 
  // Uses an ETL definition with a target table of sys_user, and mappings for the active, 
  //email, first name, and last name fields
  var transformer = new sn_impex.RTETransformer("c58f1c6377110110f5455d14cd5a998b", true, "testSourceRecord", 10);
  var messages = [JSON.stringify({
    "active":"true",
    "email":"[e-mail]",
    "first_name":"Jane",
    "last_name":"Doe"
  }), 
  JSON.stringify({
    "active":"true",
    "email":"[e-mail]",
    "first_name":"John",
    "last_name":"Deer"
  })];
  var results = transformer.transform(messages);

  for (var i = 0; i < results.length; i++) { 
    var dataList = results[i].data.sys_user;
    gs.log("source record id: " + results[i].sourceRecordSysId); gs.log("status: " + results[i].status);
    for (var j = 0; j < dataList.length; j++) { 
      gs.log("First Name: " + dataList[j].first_name);
      gs.log("Last Name: " + dataList[j].last_name);
      gs.log("Email: " + dataList[j].email;
      gs.log("Active: " + dataList[j].active;
    }
  }
}

Résultats :

source record id: b29e629877130110f5455d14cd5a99ad
status: PROCESSED
First Name: Jane
Last Name: Doe
Email: [e-mail]
Active: true
First Name: John
Last Name: Deer
Email: [e-mail]
Active: true