ScriptableDataStream: Bereichsbezogen, global

  • Freigeben Version: Yokohama
  • Aktualisiert 30. Januar 2025
  • 5 Minuten Lesedauer

    • Die ScriptableDataStream -API bietet Methoden für die Interaktion mit einem Datenstrom.

    Diese Klasse kann nur in einem serverseitigen Skript verwendet werden, nachdem ein ScriptableDataStream-Objekt mit einer der folgenden APIs abgerufen wurde:

    • Die executeDataStreamAction() -Methode in der FlowAPI- Klasse Siehe FlowAPI.
    • Die getDataStream() -Methode in der ScriptableFlowRunnerResult -Klasse Siehe ScriptableFlowRunnerResult.

    Rufen Sie nach dem Abrufen eines ScriptableDataStream-Objekts die Methoden in der folgenden Reihenfolge auf:

    1. Verwenden Sie die Methode hasNext(), um zu bestimmen, ob der Datenstrom weitere Elemente enthält.
    2. Verwenden Sie die Methode „next()“, um auf das nächste Element im Stream zuzugreifen.
    3. Verwenden Sie die Methoden getItemIndex(), getItemInPageIndex()und getPageIndex() , um Informationen aus dem Stream abzurufen.
    4. Verwenden Sie die Methode schließen (), um den Stream zu schließen.

    Diese Klasse wird im Namespace sn_fd ausgeführt.

    Hinweis:
    Schließen Sie die Datenstromlogik immer in einen Versuch/Erfassung -Block ein, um Fehler abzufangen. Fügen Sie immer eine finale Anweisung ein, die mit der Methode schließen () aus der Klasse ScriptableDataStream endet, um den Datenstrom zu schließen und Leistungsprobleme zu vermeiden.

    ScriptableDataStream – schließen ()

    Schließt die Verbindung zu einem Datenstrom. Rufen Sie diese Methode immer auf, nachdem Sie alle gewünschten Vorgänge für einen Datenstrom ausgeführt haben.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Tabelle : 1. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 2. Ergebnisse
    Typ Beschreibung
    void 
    (function() {
	
	try {
​
		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_snc_my_scope.data_stream_name');
​
		// Process each item in the data stream
		while (stream.hasNext()) {
​
			// Get a single item from the data stream.
			var user = stream.next();
		
			// Only log the first item in each page
			if (stream.getItemInPageIndex() == 0) {
				gs.info('first user on page is ' + user.name);
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();

    ScriptableDataStream – getItemIndex()

    Gibt den aktuellen Index eines Elements in einem Datenstrom zurück.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Tabelle : 3. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 4. Ergebnisse
    Typ Beschreibung
    Nummer Aktueller Index eines Elements in einem Datenstrom mit nullbasierter Indizierung. 
    (function() {
	
	try {

		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_my_scope.data_stream_name');

		// Process each item in the data stream
		while (stream.hasNext()) {

			// Get a single item from the data stream.
			var User = stream.next();

			// Use the item. Example:
			// var now_GR = new GlideRecord(<table_name>);
			// now_GR.<field_name> = User.<field_name>;
			// now_GR.insert();
		
			// By default, this code snippet will terminate after 10 items.
			// Remove or modify this limit after your code has been tested.
			if (stream.getItemIndex() >= 9) {
				break;
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();

    ScriptableDataStream – getItemInPageIndex()

    Gibt den aktuellen Index eines Elements auf der aktuellen Seite in einem Datenstrom zurück.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Tabelle : 5. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 6. Ergebnisse
    Typ Beschreibung
    Nummer Aktueller Index eines Elements auf der aktuellen Seite im Datenstrom unter Verwendung der nullbasierten Indizierung. 
    (function() {
	
	try {
​
		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_snc_my_scope.data_stream_name');
​
		// Process each item in the data stream
		while (stream.hasNext()) {
​
			// Get a single item from the data stream.
			var user = stream.next();
		
			// Only log the first item in each page
			if (stream.getItemInPageIndex() == 0) {
				gs.info('first user on page is ' + user.name);
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();

    ScriptableDataStream – getPageIndex()

    Gibt den aktuellen Index einer Seite in einem Datenstrom zurück.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Tabelle : 7. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 8. Ergebnisse
    Typ Beschreibung
    Nummer Aktueller Index einer Seite in einem Datenstrom mit nullbasierter Indizierung. 
    (function() {
	
	try {

		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_my_scope.data_stream_name');

		// Process each item in the data stream
		while (stream.hasNext()) {

			// Get a single item from the data stream.
			var item = stream.next();

			// Use the item. 
			var now_GR = new GlideRecord('incident');
			now_GR.setValue('number',item.id);
			now_GR.setValue('short_description',item.name);
			now_GR.insert();
		
			// By default, this code snippet will terminate after 5 pages.
			// Remove or modify this limit after testing your code.
			if (stream.getPageIndex() >= 4) {
				break;
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();

    ScriptableDataStream – hasNext()

    Gibt „true“ zurück, falls der Datenstrom mehrere Elemente enthält.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Hinweis:
    Standardmäßig wartet die Instanz 600 Sekunden, um eine einzelne Seite mit Daten von einem MID-Serverabzurufen. Wenn beim Ausführen einer Datenstrom -Aktion über ein MID-Servereine Zeitüberschreitung auftritt, ändern Sie diese Standardeinstellung, indem Sie die Systemeigenschaft datastream_alternative_env_fetch_page_timeout_seconds erhöhen.
    Tabelle : 9. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 10. Ergebnisse
    Typ Beschreibung
    Boolean Kennzeichnung, die bestimmt, ob im Datenstrom weitere Elemente vorhanden sind. Werte:
    • wahr: Es gibt weitere Elemente, die im Datenstrom durchlaufen werden müssen.
    • „falsch“: Der Datenstrom enthält keine Elemente mehr.

    In diesem Beispiel wird ein Incident-Datensatz für jedes im Datenstrom zurückgegebene Element erstellt.

    (function() {
	
	try {

		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_my_scope.data_stream_name');

		// Process each item in the data stream
		while (stream.hasNext()) {

			// Get a single item from the data stream.
			var item = stream.next();

			// Use the item. 
			var now_GR = new GlideRecord('incident');
			now_GR.setValue('number',item.id);
			now_GR.setValue('short_description',item.name);
			now_GR.insert();
		
			// By default, this code snippet will terminate after 10 items.
			// Remove or modify this limit after testing your code.
			if (stream.getItemIndex() >= 9) {
				break;
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();

    ScriptableDataStream – Next()

    Gibt das nächste Element in einem Datenstrom zurück.

    Sie können diese Methode nur für ein ScriptableDataStream-Objekt aufrufen, das von der executeDataStreamAction()- Methode in der FlowAPI-Klasse zurückgegeben wird. Siehe FlowAPI.

    Hinweis:
    Standardmäßig wartet die Instanz 600 Sekunden, um eine einzelne Seite mit Daten von einem MID-Serverabzurufen. Wenn beim Ausführen einer Datenstrom -Aktion über ein MID-Servereine Zeitüberschreitung auftritt, ändern Sie diese Standardeinstellung, indem Sie die Systemeigenschaft datastream_alternative_env_fetch_page_timeout_seconds erhöhen.
    Tabelle : 11. Parameter
    Name Typ Beschreibung
    Keine
    Tabelle : 12. Ergebnisse
    Typ Beschreibung
    Objekt Nächstes Element im Datenstrom. Dieses Objekt enthält die durch die Datenstromaktion definierten Ausgaben. Um die Ausgaben der Datenstromaktion anzuzeigen, navigieren Sie in der Flow Designer-Schnittstelle zum Abschnitt Ausgaben der Datenstromaktion.

    In diesem Beispiel wird ein Incident-Datensatz für jedes im Datenstrom zurückgegebene Element erstellt.

    (function() {
	
	try {

		// Execute Data Stream Action. 
		var stream = sn_fd.FlowAPI.executeDataStreamAction('x_my_scope.data_stream_name');

		// Process each item in the data stream
		while (stream.hasNext()) {

			// Get a single item from the data stream.
			var item = stream.next();

			// Use the item. 
			var now_GR = new GlideRecord('incident');
			now_GR.setValue('number',item.id);
			now_GR.setValue('short_description',item.name);
			now_GR.insert();
		
			// By default, this code snippet will terminate after 10 items.
			// Remove or modify this limit after testing your code.
			if (stream.getItemIndex() >= 9) {
				break;
			}
		}		
	} catch (ex) {
		var message = ex.getMessage();
		gs.error(message);
	} finally {
		stream.close();
	}
	
})();