Hello. Im working on a dashboard that pulls sensordata from an API. However, I'm struggeling to understand how this API expects me to handle its calls as i have not seen anything like this before.
The documentation describes the following:
Get a Batch of New Samples
Returns all the samples since the last delivered sample id, from all streams to which the client has access. sampleID and backfillHours are mutually exclusive; if you define both, backfillHours is ignored. If neither is defined, the API returns a batch of samples since its internal last delivered sample id.
The recommended use of this API is as follows:
1. The first time you call this API, specify a sampleID or backfillHours to define the starting point from which to provide the batch of samples. In addition, set enableAck to true so that the system will not update its internal last delivered sample id field based on the last sample sent in this batch.
2. After each getSamplesBatch call, call ackSamplesBatch to set the internal `last delivered sample id.
3. In all getSamplesBatch calls except the first one, do not specify a sampleID or backfillHours.
If the batch consists of over 10,000 samples, it is broken down into chunks of no more than 10,000 samples each, sent consecutively. The hasMore return flag indicates whether a given chunk is the last chunk.
Note that samples are not sent in chronological order. You may receive a sample from today followed by a sample from yesterday, depending on when each device transmitted its data.
GetAck: https://XXXXXXXX/batch/ack?id=&agent=
GetSample: https://XXXXXXX/batch?enableAck=&sampleID=&backfillHours=
So, basically, i have to call the API for the first time with parameters and after that, I have to check wether the hasMore flag returns true and if so, pull out the last SampleID from the data, feed it to the acklink and call the getsample api again without any parameters and continue looping this until the hasMore flag returns False.
I'm quite new to M-code so i think i lack the knowledge of how to handle this best.
So far i have this. It returns an error. I use parameters for the headers:
let
GetPage2 = (id as text) =>
let
Ack = Web.Contents("https://XXXXX/batch/ack?sampleId=" & id & "&agent=",
[Headers = [#"Authorization"=#"Get Security Key"]]),
data = Web.Contents("https://XXXXX/batch?enableAck=false&sampleID=&backfillHours=",
[Headers = [#"Authorization"=#"Get Security Key"]]),
result = Json.Document(data),
hasmore = result[hasMore],
samples = result[samples],
samples1 = List.Last(samples),
id = samples1[id],
pages = List.Combine(result,lijst),
continue =
if hasmore = "TRUE"
then @GetPage2(id)
else pages
in
continue,
data = Web.Contents("https://XXXXX/batch?enableAck=false&sampleID=&backfillHours=168",
[Headers = [#"Authorization"=#"Get Security Key"]]),
lijst= Json.Document(data),
hasmore = lijst[hasMore],
samples = lijst[samples],
samples1 = List.Last(samples),
id = Text.From(samples1[id]),
Complete = @GetPage2(id)
in
Complete
