QueryStreamEntriesWithData
Описание
Этот сервис можно использовать для запроса записей потока на основе указанных входных параметров. Результат будет содержать идентификатор записи, расположение, источник, тип источника, теги данных, метку времени и поля, определенные в структуре данных, связанной с потоком.
Входные данные
Имя параметра
Описание
Базовый тип
maxItems
Максимальное число возвращаемых элементов в наборе результатов. Значение по умолчанию: 500. Этот параметр применяется после применения всех остальных фильтров.
NUMBER
source
Источник записи потока. После создания записи потока необходимо выбрать действительный source_type. Этот источник может иметь теги модели.
STRING
tags
Теги данных, связанные с записью потока.
TAGS
sourceTags
Теги модели, связанные с источником этой записи.
TAGS
startDate
Метка времени, после которой была создана запись потока.
DATETIME
endDate
Метка времени, до которой была создана запись потока.
DATETIME
oldestFirst
Загрузить из самых старых или новейших записей. Значение по умолчанию: false.
BOOLEAN
query
Критерии запроса для фильтрации данных.
Дополнительные сведения см. в разделе Параметр запроса для сервисов запросов
QUERY
Вывод
Имя параметра
Описание
Базовый тип
result
Возвращает таблицу данных, содержащую идентификатор записи, расположение, источник, тип источника, теги данных, метку времени и поля, определенные в структуре данных, связанной с потоком.
INFOTABLE
Пример
В следующем примере поток TestStream имеет структуру данных с Property1, Property2 и Property3.
Сущность
Теги модели
Administrator
System
Thing1
{vocabulary: "MT1", vocabularyTerm: "MT1-MTerm1"}
entry_id
source
source_type
location
Теги данных
Property1
Property2
Property3
1
System
User
1
2
3
2
Administrator
User
a
b
c
3
Thing1
Thing
{vocabulary: "DataTag1", vocabularyTerm: "DT1-Term1"}
1
2
3
4
AAA
Неизвестные
aa
bb
cc
5
Thing1
Thing
{vocabulary: "DataTag1", vocabularyTerm: "DT1-Term1"}
1
2
3
В следующем примере показан запрос для записей потока с использованием всех поддерживаемых параметров. Этот вызов API возвращает таблицу данных, которая содержит идентификатор записи, расположение, источник, тип источника, теги данных записи потока, метку времени, Property1, Property2 и Property3:
result = Things["TestStream"].QueryStreamEntriesWithData({
maxItems: 50,
source: 'Thing1',
tags: "DataTag1:DT1-Term1", /* Data tags on Stream Entry */
sourceTags: "MT1:MT1-MTerm1", /* Model tags on Source entity */
startDate: new Date(new Date().setFullYear(new Date().getFullYear() - 1)),
endDate: Date.now(),
oldestFirst: false,
query: "{ \"sorts\": [{\"fieldName\": \"Property1\"}]}"
});
Было ли это полезно?