| 
						
						
							
								
							
						
						
					 | 
					 | 
					@ -44,8 +44,8 @@ class StatLog: | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					def main(): | 
					 | 
					 | 
					 | 
					def main(): | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					  def get_influxdb_line(measurement: str, value: float, timestamp: datetime, tags: dict): | 
					 | 
					 | 
					 | 
					  def get_influxdb_line(measurement: str, value: float, timestamp: datetime, tags: dict): | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    res = f"{measurement}" | 
					 | 
					 | 
					 | 
					    res = f"{measurement}" | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    for tag_key in tags.keys(): | 
					 | 
					 | 
					 | 
					    for k, v in tags.items(): | 
				
			
			
				
				
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      res += f",{tag_key}={str(tags[tag_key])}" | 
					 | 
					 | 
					 | 
					      res += f",{k}={str(v)}" | 
				
			
			
				
				
			
		
	
		
		
	
		
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    res += f" value={value} {int(timestamp.timestamp() * 1e9)}\n" | 
					 | 
					 | 
					 | 
					    res += f" value={value} {int(timestamp.timestamp() * 1e9)}\n" | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					    return res | 
					 | 
					 | 
					 | 
					    return res | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					
 | 
					 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
							
								
							
						
						
					 | 
					 | 
					@ -101,7 +101,7 @@ def main(): | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      current_time = datetime.utcnow().replace(tzinfo=timezone.utc) | 
					 | 
					 | 
					 | 
					      current_time = datetime.utcnow().replace(tzinfo=timezone.utc) | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      tags['started'] = sm['deviceState'].started | 
					 | 
					 | 
					 | 
					      tags['started'] = sm['deviceState'].started | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					
 | 
					 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      for gauge_key in gauges.keys(): | 
					 | 
					 | 
					 | 
					      for gauge_key in gauges: | 
				
			
			
				
				
			
		
	
		
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					        result += get_influxdb_line(f"gauge.{gauge_key}", gauges[gauge_key], current_time, tags) | 
					 | 
					 | 
					 | 
					        result += get_influxdb_line(f"gauge.{gauge_key}", gauges[gauge_key], current_time, tags) | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					
 | 
					 | 
					 | 
					 | 
					
 | 
				
			
			
		
	
		
		
			
				
					
					 | 
					 | 
					 | 
					      # clear intermediate data | 
					 | 
					 | 
					 | 
					      # clear intermediate data | 
				
			
			
		
	
	
		
		
			
				
					| 
						
							
								
							
						
						
						
					 | 
					 | 
					
  |