DS Filter

Интерфейс формирует собственные датастримы Datastream на основании встроенных. Позволяет формировать пользовательские потоки на основе одного из базовых. При расчёте изменения вызывается DS Filter в который передаётся обработанная запись. Вовзращаемое значение записывается в новый datastream. Настройки находятся в меню Основные (Main) -> Настройки (Setup) -> DataStream Config

DS Filter применяются во время расчёта данных исходного (source) датастрима (Datastream).

ds_filter(data_record):
    Implements Datastream Filter

    :param data_record: Source datastream data record
    :returns: new data

Примеры

Вернуть данные

import datetime
from noc.sa.models.managedobject import ManagedObject


def ds_filter(data_record):
    mo = ManagedObject.get_by_id(data_record["id"])
    ts = datetime.datetime.now()
    yield {
        "managed_object": mo.bi_id,
        "name": mo.name,
        "ip": mo.address,
        "ts": ts.strftime("%Y-%m-%d %H:%M:%S"),
    }