@@ -202,7 +202,7 @@ def add_feed_callback(self, feed_key, callback_method):
202
202
203
203
"""
204
204
self ._client .add_topic_callback (
205
- "{0}/feeds /{1}" .format (self ._user , feed_key ), callback_method
205
+ "{0}/f /{1}" .format (self ._user , feed_key ), callback_method
206
206
)
207
207
208
208
def remove_feed_callback (self , feed_key ):
@@ -214,7 +214,7 @@ def remove_feed_callback(self, feed_key):
214
214
:param str feed_key: Adafruit IO feed key.
215
215
216
216
"""
217
- self ._client .remove_topic_callback ("{0}/feeds /{1}" .format (self ._user , feed_key ))
217
+ self ._client .remove_topic_callback ("{0}/f /{1}" .format (self ._user , feed_key ))
218
218
219
219
def loop (self ):
220
220
"""Manually process messages from Adafruit IO.
@@ -251,11 +251,11 @@ def subscribe(self, feed_key=None, group_key=None, shared_user=None):
251
251
client.subscribe([('temperature'), ('humidity')])
252
252
"""
253
253
if shared_user is not None and feed_key is not None :
254
- self ._client .subscribe ("{0}/feeds /{1}" .format (shared_user , feed_key ))
254
+ self ._client .subscribe ("{0}/f /{1}" .format (shared_user , feed_key ))
255
255
elif group_key is not None :
256
- self ._client .subscribe ("{0}/groups /{1}" .format (self ._user , group_key ))
256
+ self ._client .subscribe ("{0}/g /{1}" .format (self ._user , group_key ))
257
257
elif feed_key is not None :
258
- self ._client .subscribe ("{0}/feeds /{1}" .format (self ._user , feed_key ))
258
+ self ._client .subscribe ("{0}/f /{1}" .format (self ._user , feed_key ))
259
259
else :
260
260
raise AdafruitIO_MQTTError ("Must provide a feed_key or group_key." )
261
261
@@ -332,11 +332,11 @@ def unsubscribe(self, feed_key=None, group_key=None, shared_user=None):
332
332
333
333
"""
334
334
if shared_user is not None and feed_key is not None :
335
- self ._client .unsubscribe ("{0}/feeds /{1}" .format (shared_user , feed_key ))
335
+ self ._client .unsubscribe ("{0}/f /{1}" .format (shared_user , feed_key ))
336
336
elif group_key is not None :
337
- self ._client .unsubscribe ("{0}/groups /{1}" .format (self ._user , feed_key ))
337
+ self ._client .unsubscribe ("{0}/g /{1}" .format (self ._user , feed_key ))
338
338
elif feed_key is not None :
339
- self ._client .unsubscribe ("{0}/feeds /{1}" .format (self ._user , feed_key ))
339
+ self ._client .unsubscribe ("{0}/f /{1}" .format (self ._user , feed_key ))
340
340
else :
341
341
raise AdafruitIO_MQTTError ("Must provide a feed_key or group_key." )
342
342
@@ -416,18 +416,18 @@ def publish(self, feed_key, data, metadata=None, shared_user=None, is_group=Fals
416
416
417
417
"""
418
418
if is_group :
419
- self ._client .publish ("{0}/groups /{1}" .format (self ._user , feed_key ), data )
419
+ self ._client .publish ("{0}/g /{1}" .format (self ._user , feed_key ), data )
420
420
if shared_user is not None :
421
- self ._client .publish ("{0}/feeds /{1}" .format (shared_user , feed_key ), data )
421
+ self ._client .publish ("{0}/f /{1}" .format (shared_user , feed_key ), data )
422
422
if metadata is not None :
423
423
if isinstance (data , int or float ):
424
424
data = str (data )
425
425
csv_string = data + "," + metadata
426
426
self ._client .publish (
427
- "{0}/feeds /{1}/csv" .format (self ._user , feed_key ), csv_string
427
+ "{0}/f /{1}/csv" .format (self ._user , feed_key ), csv_string
428
428
)
429
429
else :
430
- self ._client .publish ("{0}/feeds /{1}" .format (self ._user , feed_key ), data )
430
+ self ._client .publish ("{0}/f /{1}" .format (self ._user , feed_key ), data )
431
431
432
432
def get (self , feed_key ):
433
433
"""Calling this method will make Adafruit IO publish the most recent
@@ -440,7 +440,7 @@ def get(self, feed_key):
440
440
441
441
io.get('temperature')
442
442
"""
443
- self ._client .publish ("{0}/feeds /{1}/get" .format (self ._user , feed_key ), "\0 " )
443
+ self ._client .publish ("{0}/f /{1}/get" .format (self ._user , feed_key ), "\0 " )
444
444
445
445
446
446
class IO_HTTP :
0 commit comments