Mosquitto の sub.py を実行した際に出力されるretainのデータを、ブラウザで表示させたいです。

Question

###前提・実現したいこと
[日本語が下手]
Mosquitto の sub.py を php で実行させ、その retain のデータをブラウザで表示させたいです。
###発生している問題・エラーメッセージ
おそらく、mqttc.loop_forever() で処理が終わらずphpで表示出来ていないのだと思います、

よろしくお願いします!!

###ソースコード
sub.py

import sys
try:
    import paho.mqtt.client as mqtt
except ImportError:
    # This part is only required to run the example from within the examples
    # directory when the module itself is not installed.
    # If you have the module installed, just use "import paho.mqtt.client"
    import os
    import inspect
    cmd_subfolder = os.path.realpath(os.path.abspath(os.path.join(os.path.split(inspect.getfile( inspect.currentframe() ))[0],"../src")))
    if cmd_subfolder not in sys.path:
        sys.path.insert(0, cmd_subfolder)
    import paho.mqtt.client as mqtt

def on_connect(mqttc, obj, rc):
    print("rc: "+str(rc))

def on_message(mqttc, obj, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))

def on_publish(mqttc, obj, mid):
    print("mid: "+str(mid))

def on_subscribe(mqttc, obj, mid, granted_qos):
    print("Subscribed: "+str(mid)+" "+str(granted_qos))

def on_log(mqttc, obj, level, string):
    print(string)

# If you want to use a specific client id, use
# mqttc = mqtt.Client("client-id")
# but note that the client id must be unique on the broker. Leaving the client
# id parameter empty will generate a random id for you.
mqttc = mqtt.Client()
mqttc.on_message = on_message
mqttc.on_connect = on_connect
mqttc.on_publish = on_publish
mqttc.on_subscribe = on_subscribe
# Uncomment to enable debug messages
# mqttc.on_log = on_log
mqttc.connect("192.168.33.20", 1883, 60)
mqttc.subscribe("kut", 0)

mqttc.loop_forever()

call.php

<?php
echo "test";
   $fullPath = 'python sub.py';
    passthru($fullPath,$outpara);
    var_dump($fullPath);
    var_dump($outpara);
?>

###補足情報(言語/FW/ツール等のバージョンなど)
環境
Mac OS X El Capitan 10.11.2
ブローカサーバ : Ubuntu 14.04
サブスクサーバ : Ubuntu 14.04
vagrant apache2
mqttクライアント : paho

Answer 1

mqttc.loop_forever() で処理が終わらずphpで表示出来ていないのだと思います、

そのとおりだと思います。

以下ようにしてはいかがでしょう?

• sub.py の on_message などで php で表示させたいデータを一旦ファイルなどに出力してく
• sub.py は php から起動せずに別途起動しておく
• php は sub.py が書き出したファイルを読み込み表示する