{"id":47,"date":"2014-07-09T10:23:48","date_gmt":"2014-07-09T01:23:48","guid":{"rendered":"http:\/\/appw.jp\/2014\/?p=47"},"modified":"2016-10-28T14:15:37","modified_gmt":"2016-10-28T05:15:37","slug":"mosquitto-%e3%81%ae-payload-%e3%82%92-mongodb-%e3%81%ab%e4%bf%9d%e5%ad%98%e3%81%97%e3%81%a6%e3%81%bf%e3%82%8b","status":"publish","type":"post","link":"https:\/\/appw.jp\/2014\/?p=47","title":{"rendered":"Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b"},"content":{"rendered":"

\u300cMosquitto \u3092 VPN \u3067\u8a66\u3057\u307e\u3057\u305f<\/a>\u300d\u304b\u3089\uff12\u30f6\u6708\u304c\u7d4c\u3061\u307e\u3059\u3002<\/p>\n

\u8a66\u3057\u3066\u307f\u305f\u3044\u3053\u3068\u304c\u3044\u304f\u3064\u304b\u3042\u308a\u307e\u3057\u3066\u3001\u4eca\u56de\u306f\u3001Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b\u3053\u3068\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n

\u74b0\u5883\u306f\u3001ConoHa VPS<\/a>\"\" \u3067\u3001CentOS 6.5 \u3067\u3059\u3002<\/p>\n

Mosquitto \u306e Python \u30b5\u30f3\u30d7\u30eb\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u53c2\u8003\u306b\u3001MongoDB \u3078\u306e\u30a2\u30af\u30bb\u30b9\u3092\u66f8\u304d\u52a0\u3048\u3066\u307f\u307e\u3057\u305f\u3002<\/p>\n

\r\nimport os, sys\r\nimport time\r\nfrom datetime import datetime\r\nimport paho.mqtt.client as paho\r\n\r\nsys.path.append(os.path.dirname(os.path.abspath(__file__)) + '\/..\/model')\r\nfrom mchat import (connecter, ChatLog)\r\n\r\ndef on_connect(mosq, obj, rc):\r\n    print("on connect [rc]:" + str(rc))\r\n\r\ndef on_message(mosq, obj, msg):\r\n    now = int(time.mktime(datetime.now().timetuple()))\r\n    ChatLog(text=msg.payload, user='MQTT', created_at=now).save() \r\n    print("on message [topic]:"+msg.topic + "  [qos]:" + str(msg.qos) + "  [payload]:" + str(msg.payload))\r\n\r\ndef on_publish(mosq, obj, mid):\r\n    print("on publish [mid]:" + str(mid))\r\n\r\ndef on_subscribe(mosq, obj, mid, granted_qos):\r\n    print("on subscribe [mid]:" + str(mid) + " [qos]:" + str(granted_qos))\r\n\r\ndef on_disconnect(mosq, obj, rc):\r\n    print("on disconnect [rc]:" + str(rc))\r\n\r\ndef on_log(mosq, obj, level, string):\r\n    print(string)\r\n\r\nmqttc = paho.Client()\r\n\r\nmqttc.on_message = on_message\r\nmqttc.on_connect = on_connect\r\nmqttc.on_publish = on_publish\r\nmqttc.on_subscribe = on_subscribe\r\nmqttc.on_disconnect = on_disconnect\r\n\r\nmqttc.username_pw_set("mqtt", "mqttpasswd")\r\nmqttc.connect("localhost", 1883, 60)\r\n\r\nconnecter()\r\n\r\nmqttc.subscribe("test\/chat", 0)\r\n\r\nmqttc.publish("test\/chat", "conected mqtt subscribe")\r\n\r\nmqttc.loop_forever()\r\n<\/pre>\n
-\uff08\u30db\u30fc\u30e0\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\uff09\/test\/mqtt\/sub.py \u3067\u4fdd\u5b58\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u5f53\u521d\u306f\u3001Mosquitto \u306e Python \u30e2\u30b8\u30e5\u30fc\u30eb\u3067\u9032\u3081\u3066\u3044\u307e\u3057\u305f\u304c\u3001\u9014\u4e2d\u3067 Paho \u306b\u5207\u308a\u66ff\u3048\u307e\u3057\u305f\u3002Paho MQTT Python Client<\/a><\/p>\n
MongoDB \u30a2\u30af\u30bb\u30b9\u90e8\u5206\u306f\u3001\u4eca\u5f8c\u4f5c\u6210\u3059\u308b Web \u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u3067\u3082\u5229\u7528\u3059\u308b\u3053\u3068\u3068\u3057\u307e\u3057\u305f\u306e\u3067\u3001\u3044\u308f\u3086\u308b MVC \u306b\u304a\u3051\u308b\u30e2\u30c7\u30eb\u3068\u3057\u3066\u3001\u5225\u306e\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u3067\u30e2\u30b8\u30e5\u30fc\u30eb\u3068\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\nfrom mongoengine import *\r\n\r\nclass ChatLog(Document):\r\n    text = StringField(required=True)\r\n    user = StringField(required=True)\r\n    created_at = LongField(required=True)\r\n\r\ndef connecter():\r\n    con = connect('chattest')\r\n    print con\r\n<\/pre>\n
-\uff08\u30db\u30fc\u30e0\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\uff09\/test\/model\/mchat.py \u3067\u4fdd\u5b58\u3057\u307e\u3057\u305f<\/p>\n
MongoEngine<\/a> \u306f\u3001\u30b5\u30f3\u30d7\u30eb\u3092\u8abf\u3079\u3066\u3044\u305f\u3068\u304d\u3001\u305f\u307e\u305f\u307e\u53c2\u8003\u306b\u3057\u3066\u3044\u305f\u30bd\u30fc\u30b9\u3067\u5229\u7528\u3055\u308c\u3066\u3044\u307e\u3057\u305f\u306e\u3067\u3002<\/p>\n
created_at \u306f\u3001\u5f53\u521d\u306f\u30c7\u30d5\u30a9\u30eb\u30c8\u3067\u30bb\u30c3\u30c8\u3057\u3066\u3044\u307e\u3057\u305f\u304c\u3001PHP \u304b\u3089\u3082 MongoDB \u306b\u30a2\u30af\u30bb\u30b9\u3057\u3066\u307f\u305f\u3044\u3068\u601d\u3044\u5909\u66f4\u3057\u3066\u3044\u307e\u3059\u3002\u3053\u3053\u306b\u306f UNIXTIME \u3092\u8a2d\u5b9a\u3059\u308b\u3053\u3068\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\npython sub.py\r\n<\/pre>\n
\u3067\u8d77\u52d5\u3057\u307e\u3059\u304c\u3001\u81ea\u52d5\u3067\u30b9\u30bf\u30fc\u30c8\u3055\u305b\u3066\u307f\u305f\u3044\u3068\u601d\u3044\u3001Supervisor<\/a> \u306e\u5229\u7528\u3092\u8a66\u3057\u3066\u307f\u307e\u3057\u305f\u3002<\/p>\n
\r\nsudo yum install supervisor\r\n<\/pre>\n
EPEL \u30ec\u30dd\u30b8\u30c8\u30ea\u304b\u3089\u30d0\u30fc\u30b8\u30e7\u30f3 2.1 \u304c\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3067\u304d\u307e\u3057\u305f\u3002supervisor \u306e\u8a2d\u5b9a\u306b\u3064\u3044\u3066\u691c\u7d22\u3059\u308b\u3068\u3001\u30d0\u30fc\u30b8\u30e7\u30f3 3.x \u306e\u3082\u306e\u304c\u591a\u304f\u307f\u3089\u308c\u307e\u3059\u304c\u3001\u30d0\u30fc\u30b8\u30e7\u30f3 2.x \u3068\u306f\u69cb\u9020\u304c\u5909\u66f4\u3055\u308c\u3066\u3044\u307e\u3059\u306e\u3067\u8981\u6ce8\u610f\u3067\u3059\u3002\u3068\u306f\u3044\u3048\u3001\/etc\/supervisord.conf \u5185\u306e\u30b3\u30e1\u30f3\u30c8\u8aac\u660e\u306b\u305d\u3063\u3066\u8a2d\u5b9a\u3092\u9032\u3081\u308c\u3070\u30b3\u30f3\u30c8\u30ed\u30fc\u30eb\u3067\u304d\u307e\u3057\u305f\u3002<\/p>\n
\r\n[supervisord]\r\nhttp_port=\/var\/tmp\/supervisor.sock ; (default is to run a UNIX domain socket server)\r\nhttp_port=127.0.0.1:9001  ; (alternately, ip_address:port specifies AF_INET)\r\n\r\n;\uff5e\u9014\u4e2d\u7701\u7565\uff5e\r\n\r\n[supervisorctl]\r\nserverurl=unix:\/\/\/var\/tmp\/supervisor.sock ; use a unix:\/\/ URL  for a unix socket\r\nserverurl=http:\/\/127.0.0.1:9001 ; use an http:\/\/ url to specify an inet socket\r\n\r\n;\uff5e\u9014\u4e2d\u7701\u7565\uff5e\r\n\r\n;\uff5e\u4ee5\u4e0b\u8ffd\u52a0\uff5e\r\n[program:mqttsub]\r\ncommand=python \/home\/hoge\/test\/mqtt\/sub.py            ; the program (relative uses PATH, can take args)\r\npriority=999                ; the relative start priority (default 999)\r\nautostart=true              ; start at supervisord start (default: true)\r\nautorestart=true            ; retstart at unexpected quit (default: true)\r\nstartsecs=10                ; number of secs prog must stay running (def. 10)\r\nstartretries=3              ; max # of serial start failures (default 3)\r\nexitcodes=0,2               ; 'expected' exit codes for process (default 0,2)\r\nstopsignal=QUIT             ; signal used to kill process (default TERM)\r\nstopwaitsecs=10             ; max num secs to wait before SIGKILL (default 10)\r\nuser=hoge                   ; setuid to this UNIX account to run the program\r\nlog_stdout=true             ; if true, log program stdout (default true)\r\nlog_stderr=true             ; if true, log program stderr (def false)\r\nlogfile=\/var\/log\/supervisor\/mqttsub.log    ; child log path, use NONE for none; default AUTO\r\nlogfile_maxbytes=1MB        ; max # logfile bytes b4 rotation (default 50MB)\r\nlogfile_backups=10          ; # of logfile backups (default 10)\r\n<\/pre>\n
\u3055\u3066\u6b21\u56de\u306f\u3001HTML5 \u306e Server-Sent Events \u3068 PHP \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u3001\u3053\u306e MongoDB \u306b\u4fdd\u5b58\u3057\u305f Mosquitto \u306e payload \u3092\u8868\u793a\u3057\u3066\u3044\u304d\u305f\u3044\u3068\u601d\u3044\u307e\u3059\u3002\u300cServer-Sent Events\uff08EventSource\uff09\u3092\u8a66\u3057\u3066\u307f\u307e\u3059<\/a>\u300d\u4ee5\u6765\u3001Server-Sent Events\uff08EventSource\uff09\u3092\u5229\u7528\u3059\u308b\u6a5f\u4f1a\u3092\u5f85\u3063\u3066\u3044\u307e\u3057\u305f\u3002<\/p>\n
\u3055\u3089\u306b\u5510\u7a81\u3067\u306f\u3042\u308a\u307e\u3059\u304c\u3001Python \u3067\u306e Web \u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306b\u3082\u30c8\u30e9\u30a4\u3057\u3066\u307f\u307e\u3059\u3002<\/p>\n<\/svg>\n
\u4eca\u56de\u306e\u7b2c\uff11\u56de\u306f\u3001Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u6b21\u56de\u306e\u7b2c\uff12\u56de\u306f\u3001HTML5 \u306e Server-Sent Events \u3068 PHP \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3057\u307e\u3059\u3002
\n\u300cMongoDB \u306b\u4fdd\u5b58\u3057\u305f Mosquitto \u306e payload \u3092 Server-Sent Events \u3067\u8868\u793a\u3057\u3066\u307f\u308b<\/a>\u300d<\/p>\n
\u7b2c\uff13\u56de\u306f\u3001Python \u3067 WebSocket \u3092\u5229\u7528\u3057\u305f\u7c21\u5358\u306a\u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u53c2\u8003\u306b MongoDB \u30a2\u30af\u30bb\u30b9\u3092\u66f8\u304d\u52a0\u3048\u3066\u307f\u307e\u3059\u3002
\n\u300cPython WebSocket \u306e\u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u306b\u3001MongoDB \u4fdd\u5b58\u3092\u4ed8\u3051\u52a0\u3048\u307e\u3057\u305f<\/a>\u300d<\/p>\n
\u7b2c\uff14\u56de\u306f\u3001\u7b2c\uff13\u56de\u306e Python \u306e WebSocket \u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u53c2\u8003\u306b\u3057\u3064\u3064\u3001\u30d6\u30e9\u30a6\u30b6\u304b\u3089 POST \u30e1\u30bd\u30c3\u30c9\u3067 Mosquitto \u3078 Publish \u3057\u3001\u307e\u305f\u3001Server-Sent Events \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3059\u308b\u65b9\u5f0f\u3092 Python \u3067\u8a66\u3057\u3066\u307f\u307e\u3059\u3002
\n\u300cMosquitto Publish \u3068 Server-Sent Events \u3067 Python \u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u3092\u6539\u9020<\/a>\u300d<\/p>\n
\u307e\u305f\u3001\u300cMosquitto \u3078 SSL \u3067\u63a5\u7d9a\u3057\u3066\u307f\u308b<\/a>\u300d\u3067\u306f\u3001SSL\/TLS \u3067\u306e\u63a5\u7d9a\u306b\u30c8\u30e9\u30a4\u3057\u307e\u3059\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u300cMosquitto \u3092 VPN \u3067\u8a66\u3057\u307e\u3057\u305f\u300d\u304b\u3089\uff12\u30f6\u6708\u304c\u7d4c\u3061\u307e\u3059\u3002 \u8a66\u3057\u3066\u307f\u305f\u3044\u3053\u3068\u304c\u3044\u304f\u3064\u304b\u3042\u308a\u307e\u3057\u3066\u3001\u4eca\u56de\u306f\u3001Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b\u3053\u3068\u306b\u3057\u307e\u3057\u305f\u3002 \u74b0\u5883\u306f\u3001C […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2],"tags":[],"class_list":["post-47","post","type-post","status-publish","format-standard","hentry","category-vps"],"_links":{"self":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/47","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=47"}],"version-history":[{"count":10,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/47\/revisions"}],"predecessor-version":[{"id":161,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/47\/revisions\/161"}],"wp:attachment":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=47"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=47"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=47"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}