$ python3 scan_ble_devices.py

$ python3 get_device_uuids.py 02:B3:EC:C3:4B:A6

# -*- coding: utf-8 -*-
import sys
import asyncio
from bleak import BleakClient

import paho.mqtt.client as mqtt
import time
import json
import urllib.request
import struct

# setting for BLE
ADDRESS = (
    "02:B3:EC:C3:4B:A6" # Anemometer BTMETER BT-100-APP
)
# UUID for notify
CHARACTERISTIC_UUID1 = "0000ffb2-0000-1000-8000-00805f9b34fb" # read & notify

# MQTT ブローカーの設定
broker_address = "localhost"
port = 1883
topic = "anemometer"
# MQTT クライアントを作成
mqtt_client = mqtt.Client()

sdata = {    # 辞書型データ
    'sensor': 'BT-100-APP',
    'func':'Anemometer',
    'temp': 20.0,
    'unit-t':'deg',
    'velocity': 0.0,
    'unit-v':'m/s'
}

def publish(sdata):
    # Publish on MQTT
    # JSON データを文字列に変換
    json_data = json.dumps(sdata)
    # トピックに JSON データをパブリッシュ
    mqtt_client.publish(topic, json_data)
    
def parse_comma_separated_numbers(input_string):
    # カンマで文字列を分割し、各部分を浮動小数点数に変換
    parts = input_string.split(',')
    numbers = []
    for part in parts:
        try:
            number = float(part)
            numbers.append(number)
        except ValueError:
            # 数値に変換できない場合は無視
            pass
    return numbers

def bytes_to_hex(data):
    # bytearrayをバイト単位で16進数に変換
    data1 = ''.join(format(x, '02x') for x in data)
    # 4バイトごとの文字列に分割
    X_hex = [data1[i:i+4] for i in range(0, len(data1), 4)]
    return X_hex

def unit_read(data):
    ct = data[3]
    cv = data[2]
    unit_t = 'Error'
    unit_v = 'Error'
    
    if ct=='1' or ct=='5' or ct=='9':
        unit_t = 'degF'
    elif ct=='2' or ct=='6' or ct=='a': 
        unit_t = 'degC'

    if cv=='4':
        unit_v = 'm/s'
    elif cv=='2':
        unit_v = 'Km/h'
    elif cv=='1':
        unit_v = 'ft/min'
    elif cv=='0':
        if ct=='a' or ct=='9':
            unit_v = 'Knots'
        elif ct=='6' or ct=='5':
            unit_v = 'mph'

    return unit_t, unit_v

def conv01(sval):  # 気温 10の位
    hex_to_val = {
        'bf': 0,
        'a1': 1,
        'db': 2,
        'f9': 3,
        'e5': 4,
        '7d': 5,
        '7f': 6,
        'a9': 7,
        'ff': 8,
        'fd': 9
    }
    return hex_to_val.get(sval, 0)

def conv02(sval):   # 風速 10の位
    hex_to_val = {
        'be': 0,
        'a0': 1
    }
    return hex_to_val.get(sval, 0)
        
def conv03(sval):  # 気温、風速 1の位
    hex_to_val = {
        'be': 0,
        'a0': 1,
        'da': 2,
        'f8': 3,
        'e4': 4,
        '7c': 5,
        '7e': 6,
        'a8': 7,
        'fe': 8,
        'fc': 9
    }
    return hex_to_val.get(sval, 0)

def tens_digit(data):   # 10の位を変換
    temp = data[1]+data[3]
    velocity = data[0]+data[2]

    val_t = conv01(temp) * 10
    val_v = conv02(velocity) * 10
    return val_t, val_v

def unit_digit(data):  # 1の位を変換
    temp = data[1]+data[3]
    velocity = data[0]+data[2]

    val_t = conv03(temp)
    val_v = conv03(velocity)
    return val_t, val_v

def place_of_decimal(data):  # 小数点１位を変換
    temp = data[1]+data[3]
    velocity = data[0]+data[2]

    val_t = conv01(temp) * 0.1
    val_v = conv01(velocity) * 0.1
    return val_t, val_v

def value_read(data):
    temp = 0.0
    velocity = 0.0
    value = 0.0

    val = tens_digit(data[2])        # 10の位を変換
    temp = temp + val[0]
    velocity = velocity + val[1]
    val = unit_digit(data[1])        # 1の位を変換
    temp = temp + val[0]
    velocity = velocity + val[1]
    val = place_of_decimal(data[0])  # 小数点１位を変換
    temp = temp + val[0]
    velocity = velocity + val[1]
    return round(temp,1), round(velocity,1)

def notification_handler1(sender, data: bytearray):
    
    data1 = bytes_to_hex(data)
    unit = unit_read(data1[0]) # 単位読取
    val = value_read(data1[1:])

    sdata['temp'] = val[0]
    sdata['unit-t'] = unit[0]
    sdata['velocity'] = val[1]
    sdata['unit-v'] = unit[1]
    print(sdata)
    publish(sdata)

async def main(address):
    char_uuid1 = CHARACTERISTIC_UUID1

    # MQTT ブローカーに接続
    mqtt_client.connect(broker_address, port)
    print(f"MQTT connected: {broker_address}")

    print(address, char_uuid1)
    async with BleakClient(address) as client:
        print(f"Connected: {client.is_connected}")
        await client.start_notify(char_uuid1, notification_handler1)
        await asyncio.sleep(120.0)
        await client.stop_notify(char_uuid1)

    # MQTT クライアントを切断
    mqtt_client.disconnect()
        
if __name__ == "__main__":
    asyncio.run(
        main(
            sys.argv[1] if len(sys.argv) > 1 else ADDRESS,
        )
    )