プログラムのバックグラウンド稼働について

Question

##やろうとしていること

MQTT Messageを常時受信するSubscribeプログラムを作成し、systemdで常時稼働させています。

##困っていること
次のプログラムは、MQTTの受信（Subscribe)プログラムです。
常時受信待ちの状況にするため、このプログラムをバックグラウンドで稼働させておきたいです。

具体的には、次のコマンドを実行していたいです。
nohup python test.py

##今起きている問題
systemdで自動起動させていましたが、自動起動のたびに、client.connectするため、
同じclient_idで続けて再接続してしまいます。（MQTTの通信が受信できないことがあります。）

そのため、自動起動ではなく、バックグラウンドで起動状態にしたいのですが、
どんな方法があるのでしょうか。

##プログラム

#!/usr/bin/python
# coding: utf-8
import time
from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
import subprocess

CLIENT_ID = "hoge"
ENDPOINT = "hogehoge.amazonaws.com" # <random>.iot.<region>.amazonaws.com
PORT = 8883
ROOT_CA = "/home/pi/dev/aws/rootCA.pem" 
PRIVATE_KEY = "/home/pi/dev/aws/hogehoge.pem.key"
CERTIFICATE = "/home/pi/dev/aws/hogehoge.pem.crt"

#大文字・小文字の区別に注意
#Publishで設定しているTopicと同じに設定
TOPIC = "test"

def main():
    # setting for MQTT
    client = AWSIoTMQTTClient(CLIENT_ID)
    client.configureEndpoint(ENDPOINT, PORT)
    client.configureCredentials(ROOT_CA, PRIVATE_KEY, CERTIFICATE)
    # AWSIoTMQTTClient connection configuration
    client.configureAutoReconnectBackoffTime(1, 32, 20)
    # -1:infinite
    client.configureOfflinePublishQueueing(-1)
    # Draining: 2 Hz
    client.configureDrainingFrequency(2)
    # 10 sec
    client.configureConnectDisconnectTimeout(10)
    # 5 sec
    client.configureMQTTOperationTimeout(5)
    # Connect to AWS IoT with default keepalive set to 600 seconds 
    # keepAliveIntervalSecond : Time in seconds for interval of sending MQTT ping request. Default set to 600 seconds.
    client.connect()
    # TOPICが起動したら呼ばれる関数を登録するQoS(Quality of Service)=1
    # QoS=0:投げっぱなし,QoS=1:少なくとも1回は確実にBrokerにメッセージが届く
    client.subscribe(TOPIC, 1, mycallback)
#    time.sleep(5)
    #無限ループ
    while True:
        time.sleep(5)

def mycallback(client, userdata, message):
    print("Received message '" + str(message.payload) + "' on topic '" + message.topic + "' with QoS " + str(message.qos))
    if message.payload == "red":
        print("red")
        subprocess.check_call(['python','/home/pi/dev/RED.py'])
    elif message.payload == "blue":
        print("blue")
        subprocess.check_call(['python','/home/pi/dev/BLUE.py'])
    elif message.payload == "yellow":
        print("yellow")
        subprocess.check_call(['python','/home/pi/dev/YELLOW.py'])
    elif message.payload == "green":
        print("green")
        subprocess.check_call(['python','/home/pi/dev/GREEN.py'])
    else:
        print("RYGB")
        subprocess.check_call(['python','/home/pi/dev/RYGB.py'])


if __name__ == "__main__":
    main()

##Unitファイル

[Unit]
Description=Subscriber 
Wants=network.target

[Service]
WorkingDirectory=/home/pi/dev/plc
ExecStart=/home/pi/dev/test.py
Restart=on-failure
RestartSec=5s
User=pi
Group=pi

[Install]
WantedBy=multi-user.target

Comments

[yu_1985]

systemdによって起動された状態で
systemctl status で起動状態を見ると何かメッセージが出ていたりしませんか？
遅れていても受信はできているということは起動できていないということはない気はするのですが…。

[raspypy]

起動状態は"active (running)"です。
おっしゃるとおり、起動できていないということはないのですが、受信が遅れてしまいます。
プログラムを実行した状態では、受信が遅れることがないので、原因が分からず困っております。

[yu_1985]

起動状態そのものだけを見るのではなく、一緒に出ている起動時のメッセージになにか出ていないかも見てみてください。

また、切り分けのために、pythonを直接実行するのではなくシェルスクリプトを経由して該当のプログラムを実行させるようにしてみてください。
https://qiita.com/tkato/items/6a227e7c2c2bde19521c#opt%E3%83%91%E3%83%83%E3%82%B1%E3%83%BC%E3%82%B8%E5%90%8Dbinyyyysh%E3%81%AE%E4%B8%AD%E8%BA%AB

そのプログラム自身が何かしらログを出していたらそれを見たいところですが…。

[raspypy]

journalctl -u ユニットファイル名で出力ログを確認しましたが、
ログは、MQTT受信したときの時刻となります。（送信時刻ではなく）

[yu_1985]

断片的な情報過ぎてそもそもログに何が出ているのかわからないので、どの出力を見て何を確認したのかがわかるようにできればそのまま貼ったほうが良いかと。
それが何のログかも明確ではないですし。

感覚的には、受信側のプログラムを動かしているので受信時刻になるのは別段おかしくないのでは、と思うのですが、そもそも見るべきなのがそこなのかわかりません。

Answer 1

systemd oneshotで実現できました。