Change to new url and auth
This commit is contained in:
parent
f8e4b797e5
commit
671c3b298e
1 changed files with 3 additions and 3 deletions
|
@ -120,10 +120,10 @@ def get_new_data():
|
||||||
past_seconds = 604800 # 7 days, max The Things Network storage allows
|
past_seconds = 604800 # 7 days, max The Things Network storage allows
|
||||||
|
|
||||||
for each_device in devices:
|
for each_device in devices:
|
||||||
endpoint = "https://{app}.data.thethingsnetwork.org/api/v2/query/{dev}?last={time}".format(
|
endpoint = "https://eu1.cloud.thethings.network/api/v3/as/applications/{app}/devices/{dev}/packages/storage/uplink_message?last={time}".format(
|
||||||
app=application, dev=each_device, time="{}s".format(past_seconds))
|
app=application, dev=each_device, time="{}s".format(past_seconds))
|
||||||
logger.info(endpoint)
|
logger.info(endpoint)
|
||||||
key = 'key {}'.format(app_key)
|
key = 'Bearer {}'.format(app_key)
|
||||||
headers = {'Authorization': key, 'Content-Type': 'application/json'}
|
headers = {'Authorization': key, 'Content-Type': 'application/json'}
|
||||||
response = requests.get(endpoint, headers=headers)
|
response = requests.get(endpoint, headers=headers)
|
||||||
if response.status_code != 200:
|
if response.status_code != 200:
|
||||||
|
@ -135,7 +135,7 @@ def get_new_data():
|
||||||
logger.info("{}, {}".format(each_resp['latitude'], each_resp['longitude']))
|
logger.info("{}, {}".format(each_resp['latitude'], each_resp['longitude']))
|
||||||
new_location = Location(
|
new_location = Location(
|
||||||
device_id=each_resp['device_id'],
|
device_id=each_resp['device_id'],
|
||||||
raw=each_resp['raw'],
|
raw='',
|
||||||
datetime_obj=parser().parse(each_resp['time']),
|
datetime_obj=parser().parse(each_resp['time']),
|
||||||
datetime=each_resp['time'],
|
datetime=each_resp['time'],
|
||||||
latitude=each_resp['latitude'],
|
latitude=each_resp['latitude'],
|
||||||
|
|
Loading…
Add table
Reference in a new issue