#! /usr/bin/env python
# -*- coding:utf-8 -*-
from time import sleep
import paho.mqtt.client as mqtt
host = 'broker.hivemq.com'
port = 1883
topic = 'nopnop2002'
# インスタンス作成時にprotocol v3.1.1を指定します
client = mqtt.Client(protocol=mqtt.MQTTv311)
client.connect(host, port=port, keepalive=60)
for i in range(2):
client.publish(topic, '1')
sleep(2)
client.publish(topic, '0')
sleep(2)
client.disconnect()
|