23
23
import re
24
24
25
25
try :
26
- from typing import List , Tuple , Any
26
+ from typing import List , Any
27
27
except ImportError :
28
28
pass
29
29
@@ -244,7 +244,9 @@ def loop(self, timeout=1):
244
244
self ._client .loop (timeout )
245
245
246
246
# Subscriptions
247
- def subscribe (self , feed_key : str = None , group_key : str = None , shared_user : str = None ):
247
+ def subscribe (
248
+ self , feed_key : str = None , group_key : str = None , shared_user : str = None
249
+ ):
248
250
"""Subscribes to your Adafruit IO feed or group.
249
251
Can also subscribe to someone else's feed.
250
252
@@ -317,7 +319,9 @@ def subscribe_to_time(self, time_type):
317
319
else :
318
320
self ._client .subscribe ("time/" + time_type )
319
321
320
- def unsubscribe (self , feed_key : str = None , group_key : str = None , shared_user : str = None ):
322
+ def unsubscribe (
323
+ self , feed_key : str = None , group_key : str = None , shared_user : str = None
324
+ ):
321
325
"""Unsubscribes from an Adafruit IO feed or group.
322
326
Can also subscribe to someone else's feed.
323
327
@@ -350,7 +354,9 @@ def unsubscribe(self, feed_key: str=None, group_key: str=None, shared_user: str=
350
354
raise AdafruitIO_MQTTError ("Must provide a feed_key or group_key." )
351
355
352
356
# Publishing
353
- def publish_multiple (self , feeds_and_data : List , timeout : int = 3 , is_group : bool = False ):
357
+ def publish_multiple (
358
+ self , feeds_and_data : List , timeout : int = 3 , is_group : bool = False
359
+ ):
354
360
"""Publishes multiple data points to multiple feeds or groups with a variable
355
361
timeout.
356
362
@@ -378,8 +384,15 @@ def publish_multiple(self, feeds_and_data: List, timeout: int=3, is_group: bool=
378
384
time .sleep (timeout )
379
385
380
386
# pylint: disable=too-many-arguments
381
- def publish (self , feed_key : str , data : Any , metadata : str = None , shared_use : str = None , is_group : bool = False ):
382
- """Publishes to an An Adafruit IO Feed.
387
+ def publish (
388
+ self ,
389
+ feed_key : str ,
390
+ data : Any ,
391
+ metadata : str = None ,
392
+ shared_user : str = None ,
393
+ is_group : bool = False ,
394
+ ):
395
+ """Publishes to an Adafruit IO Feed.
383
396
384
397
:param str feed_key: Adafruit IO Feed key.
385
398
:param str data: Data to publish to the feed or group.
@@ -564,7 +577,9 @@ def _delete(self, path: str):
564
577
return json_data
565
578
566
579
# Data
567
- def send_data (self , feed_key : str , data : str , metadata : dict = None , precision : int = None ):
580
+ def send_data (
581
+ self , feed_key : str , data : str , metadata : dict = None , precision : int = None
582
+ ):
568
583
"""
569
584
Sends value data to a specified Adafruit IO feed.
570
585
@@ -630,7 +645,7 @@ def delete_data(self, feed_key: str, data_id: str):
630
645
return self ._delete (path )
631
646
632
647
# Groups
633
- def create_new_group (self , group_key :str , group_description : str ):
648
+ def create_new_group (self , group_key : str , group_description : str ):
634
649
"""
635
650
Creates a new Adafruit IO Group.
636
651
@@ -682,7 +697,7 @@ def add_feed_to_group(self, group_key: str, feed_key: str):
682
697
return self ._post (path , payload )
683
698
684
699
# Feeds
685
- def get_feed (self , feed_key : str , detailed : bool = False ):
700
+ def get_feed (self , feed_key : str , detailed : bool = False ):
686
701
"""
687
702
Returns an Adafruit IO feed based on the feed key
688
703
@@ -696,7 +711,9 @@ def get_feed(self, feed_key: str, detailed: bool=False):
696
711
path = self ._compose_path ("feeds/{0}" .format (feed_key ))
697
712
return self ._get (path )
698
713
699
- def create_new_feed (self , feed_key : str , feed_desc : str = None , feed_license : str = None ):
714
+ def create_new_feed (
715
+ self , feed_key : str , feed_desc : str = None , feed_license : str = None
716
+ ):
700
717
"""
701
718
Creates a new Adafruit IO feed.
702
719
@@ -710,7 +727,11 @@ def create_new_feed(self, feed_key: str, feed_desc: str=None, feed_license: str=
710
727
return self ._post (path , payload )
711
728
712
729
def create_and_get_feed (
713
- self , feed_key : str , detailed : bool = False , feed_desc : str = None , feed_license : str = None
730
+ self ,
731
+ feed_key : str ,
732
+ detailed : bool = False ,
733
+ feed_desc : str = None ,
734
+ feed_license : str = None ,
714
735
):
715
736
"""
716
737
Attempts to return a feed; if the feed does not exist, it is created, and then returned.
0 commit comments