in client/iot_client.py [0:0]
def init_jobs_client(self):
print("Checking for outstanding jobs")
self.subscribe("$aws/things/{0}/jobs/get/accepted".format(self.thing_name), 0, self.init_jobs_response)
print("Subscribing to jobs detail topic")
self.subscribe(
"$aws/things/{0}/jobs/+/get/accepted".format(self.thing_name),
0,
self.job_detail_callback
)
self.publish(
"$aws/things/{0}/jobs/get".format(self.thing_name),
json.dumps({"clientToken": str(uuid.uuid4())}),
0
)
time.sleep(2)
print("Initializing new jobs listener")
self.subscribe("$aws/things/{0}/jobs/notify".format(self.thing_name), 0, self.jobs_notification_callback)