Class DataPointSubscriptionsAPI

Create data point subscriptions

const subscriptions = await client.timeseries.subscriptions.create([
  { externalId: 'my_subscription', partitionCount: 1, timeSeriesIds: ['ts_external_id'] },
]);
Copy

Delete data point subscriptions

await client.timeseries.subscriptions.delete({
  items: [{ externalId: 'my_subscription' }],
});
Copy

List data point subscriptions

const subscriptions = await client.timeseries.subscriptions.list({ limit: 100 });
Copy

List data point subscription data

const data = await client.timeseries.subscriptions.listData({
  externalId: 'my_subscription',
  partitions: [{ index: 0 }],
  limit: 100,
  initializeCursors: 'now',
});
Copy

Retrieve data point subscriptions

const subscriptions = await client.timeseries.subscriptions.retrieve({
  items: [{ externalId: 'my_subscription' }],
});
Copy

Update data point subscriptions

const updated = await client.timeseries.subscriptions.update([
  { externalId: 'my_subscription', update: { name: { set: 'new name' } } },
]);
Copy