MTMC

Methods

(async) consumeAMRMessages(messageBroker)

Description:

• consumes incoming AMR messages.

Source:

• Services/MTMC.js, line 153

Example

const mdx = require("@nvidia-mdx/web-api-core");
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
let mtmcObject = new mdx.Services.MTMC();
await mtmcObject.consumeAMRMessages(kafka);

Parameters:

(async) consumeRTLSMessages(messageBroker)

Description:

• consumes incoming rtls messages.

Source:

• Services/MTMC.js, line 142

Example

const mdx = require("@nvidia-mdx/web-api-core");
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
let mtmcObject = new mdx.Services.MTMC();
await mtmcObject.consumeRTLSMessages(kafka);

Parameters:

(async) getBehaviorsSimilarToEmbeddings(vectorDb, input) → {Promise.<Array.<Object>>}

Description:

• returns behavior info with similar embeddings from vectorDb.

Source:

• Services/MTMC.js, line 105

Example

const mdx = require("@nvidia-mdx/web-api-core");
const milvus = new mdx.Utils.Milvus({url: "milvus-url"},databaseConfigMap);
let input = {fromTimestamp: "2023-01-12T11:20:10.000Z", toTimestamp: "2023-01-12T14:20:10.000Z", embedding: embedding, sensorIdOfExample: "abc", objectIdOfExample: "120", timestampOfExampleBehavior: "2023-01-12T12:00:00.000Z" };
let mtmc = new mdx.Services.MTMC();
let similarBehaviorInfo = await mtmc.getBehaviorsSimilarToEmbeddings(milvus, input);

Parameters:

Returns:

Type

Promise.<Array.<Object>>

(async) getLocationsOfMatchedBehaviors(documentDb, input) → {Promise.<Object>}

Description:

• returns locations of matched objects.

Source:

• Services/MTMC.js, line 72

Example

const mdx = require("@nvidia-mdx/web-api-core");
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
let input = {globalId: "12", fromTimestamp: "2023-01-12T11:20:10.000Z", toTimestamp: "2023-01-12T14:20:10.000Z"};
let mtmc = new mdx.Services.MTMC();
let behaviors = await mtmc.getLocationsOfMatchedBehaviors(elastic, input);

Parameters:

Returns:

Type

Promise.<Object>

getNormalizedEmbedding(embedding) → {Array.<number>}

Description:

• returns normalized embedding.

Source:

• Services/MTMC.js, line 82

Example

const mdx = require("@nvidia-mdx/web-api-core");
let mtmc = new mdx.Services.MTMC();
let normalizedEmbedding = mtmc.getNormalizedEmbedding(embedding);

Parameters:

Returns:

Type

Array.<number>

(async) getSimilarBehaviorsBasedOnExample(documentDb, vectorDb, input) → {Promise.<Object>}

Description:

• returns an object containing scored behaviors which are similar to the input example.

Source:

• Services/MTMC.js, line 131

Example

const mdx = require("@nvidia-mdx/web-api-core");
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
const milvus = new mdx.Utils.Milvus({url: "milvus-url"},databaseConfigMap);
let input = {sensorIdOfExample: "abc", objectIdOfExample: "120", timestampOfExample: "2023-01-12T12:02:00.000Z"};
let mtmc = new mdx.Services.MTMC();
let behaviors = await mtmc.getSimilarBehaviorsBasedOnExample(elastic, milvus, input);

Parameters:

Returns:

Type

Promise.<Object>

(async) getUniqueObjectCount(documentDb, input) → {Promise.<Object>}

Description:

• returns unique object count.

Source:

• Services/MTMC.js, line 33

Example

const mdx = require("@nvidia-mdx/web-api-core");
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
let input = {sensorIds: ["abc"], timestamp: "2023-01-12T11:20:10.000Z", timeWindowInMs: 100};
let mtmc = new mdx.Services.MTMC();
let uniqueObjectCount = await mtmc.getUniqueObjectCount(elastic, input);

Parameters:

Returns:

Type

Promise.<Object>

(async) getUniqueObjectCountWithLocations(documentDb, messageBroker, input) → {Promise.<Object>}

Description:

• returns an object containing unique object count of a place with object locations.

Source:

• Services/MTMC.js, line 176

Example

const mdx = require("@nvidia-mdx/web-api-core");
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
const kafka = new mdx.Utils.Kafka({brokers: ["kafka-broker-url"]}, kafkaConfigMap);
let input = {place: "building=abc/room=xyz"};
let mtmc = new mdx.Services.MTMC();
let uniqueObjectCountWithLocations = await mtmc.getUniqueObjectCountWithLocations(elastic,kafka,input);

Parameters:

Returns:

Type

Promise.<Object>

(async) getUniqueObjects(documentDb, input) → {Promise.<Object>}

Description:

• returns unique objects.

Source:

• Services/MTMC.js, line 54

Example

const mdx = require("@nvidia-mdx/web-api-core");
const elastic = new mdx.Utils.Elasticsearch({node: "elasticsearch-url"},databaseConfigMap);
let input = {sensorIds: ["abc"], fromTimestamp: "2023-01-12T11:20:10.000Z", toTimestamp: "2023-01-12T14:20:10.000Z"};
let mtmc = new mdx.Services.MTMC();
let uniqueObjects = await mtmc.getUniqueObjects(elastic, input);

Parameters:

Returns:

Type

Promise.<Object>