ashhadulislam

curl -X POST \
  http://192.168.99.100:32358/putimage \
  -H 'Content-Type: application/json' \
  -H 'Postman-Token: 5135679d-fe27-499e-80a9-2295d436afac' \
  -H 'cache-control: no-cache' \
  -d '{
	"image_name":"test messagse"
}'

ashhadulislam

list_measure_groups=["IMU","GSR","ECG"]
device_name=["headband","fitbit","chest_mount"]

ashhadulislam

# import testdata
import json
from boto import kinesis
import sys

# seed the pseudorandom number generator
from random import seed
from random import randint
import time
import random

ashhadulislam

seed(1)

i=0
while 1==1:

    new_dict={}    
    new_dict["timestamp"]=int(time.time())        
    new_dict["dataNum"]="data"+str(i)
    new_dict["device_name"]="dev"
    new_dict["HeartRate"]=random.randint(60, 120)

ashhadulislam

kinesis.put_record("end-stream", json.dumps(new_dict), "partitionkey")    

ashhadulislam

import json
from boto import kinesis
import sys

from random import seed
from random import randint
import time
import random

kinesis = kinesis.connect_to_region("us-east-2")

ashhadulislam

{
   "MillisBehindLatest":2000,
   "NextShardIterator":"A really long shard identfier",
   "Records":[
      {
         "ApproximateArrivalTimestamp":1597844626.467,
         "Data":"The main data in string form",
         "PartitionKey":"partitionkey",
         "SequenceNumber":"A really long sequence number"
      }

ashhadulislam

{
   "MillisBehindLatest":0,
   "NextShardIterator":"Super Long shard Iterator",
   "Records":[
   ]
}

ashhadulislam

from boto import kinesis
import time

ashhadulislam

kinesis = kinesis.connect_to_region("us-east-2")
shard_id = 'shardId-000000000000' #we only have one shard!
shard_it = kinesis.get_shard_iterator("end-stream", shard_id, "LATEST")["ShardIterator"]