@@ -29,6 +29,7 @@ class ThingSpeakEventHandler(FilterEventHandler):
29
29
30
30
def __init__ (
31
31
self ,
32
+ * ,
32
33
api_key : str ,
33
34
fields : Dict [str , int ],
34
35
period : Optional [int ] = None ,
@@ -88,7 +89,7 @@ async def on_value_change(
88
89
await self .send_values (self ._values_cache , created_at )
89
90
90
91
except Exception as e :
91
- self .logger . error ('sending values failed: %s' , e , exc_info = True )
92
+ self .error ('sending values failed: %s' , e , exc_info = True )
92
93
93
94
self ._values_cache = {}
94
95
@@ -114,7 +115,7 @@ async def send_values(self, values: Dict[int, float], created_at: datetime.datet
114
115
if i in values :
115
116
field_msgs .append (f'field{ i } ={ values [i ]} ' )
116
117
117
- self .logger . debug ('sent %s at %s' , ', ' .join (field_msgs ), data ['created_at' ])
118
+ self .debug ('sent %s at %s' , ', ' .join (field_msgs ), data ['created_at' ])
118
119
119
120
async def periodic_send_values (self ) -> None :
120
121
while True :
@@ -127,13 +128,13 @@ async def periodic_send_values(self) -> None:
127
128
await self .send_values (field_values , datetime .datetime .utcnow ())
128
129
129
130
else :
130
- self .logger . debug ('not sending empty values' )
131
+ self .debug ('not sending empty values' )
131
132
132
133
except asyncio .CancelledError :
133
- self .logger . debug ('periodic send values loop cancelled' )
134
+ self .debug ('periodic send values loop cancelled' )
134
135
break
135
136
136
137
except Exception as e :
137
- self .logger . error ('sending values failed: %s' , e , exc_info = True )
138
+ self .error ('sending values failed: %s' , e , exc_info = True )
138
139
139
140
await asyncio .sleep (self ._period )
0 commit comments