質問編集履歴
3
記載漏れ追加
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -104,6 +104,8 @@
|
|
|
104
104
|
|
|
105
105
|
OS: CentOS7
|
|
106
106
|
|
|
107
|
+
DBMS: MySQL 5.7.29
|
|
108
|
+
|
|
107
109
|
言語: Python 3.6.8
|
|
108
110
|
|
|
109
111
|
MySQLモジュール: mysql-connector-python 8.0.19
|
2
文字抜け修正
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -40,7 +40,7 @@
|
|
|
40
40
|
|
|
41
41
|
|
|
42
42
|
|
|
43
|
-
接続を永続するためにmysql-connectorにはpingメソッドがあるので、それ
|
|
43
|
+
接続を永続するためにmysql-connectorにはpingメソッドがあるので、それに依存して再接続の実装はしていないのですが、pingメソッドが機能していないように思うので、なにか使い方の問題や注意点などがあればご指摘賜りたいと思います。
|
|
44
44
|
|
|
45
45
|
|
|
46
46
|
|
1
ソースコード改定
test
CHANGED
|
File without changes
|
test
CHANGED
|
@@ -58,6 +58,20 @@
|
|
|
58
58
|
|
|
59
59
|
import mysql.connector
|
|
60
60
|
|
|
61
|
+
|
|
62
|
+
|
|
63
|
+
def on_message(client, userdata, msg): # イベントドリブン
|
|
64
|
+
|
|
65
|
+
sql = "INSERT INTO event (topic) value ('{0}')".format(msg.topic)
|
|
66
|
+
|
|
67
|
+
cur = conn.cursor()
|
|
68
|
+
|
|
69
|
+
cur.execute(sql)
|
|
70
|
+
|
|
71
|
+
cur.close()
|
|
72
|
+
|
|
73
|
+
|
|
74
|
+
|
|
61
75
|
# MySQLコネクションの作成
|
|
62
76
|
|
|
63
77
|
conparm = {'host':'localhost','port':'3306', 'user': 'hoge', 'password':'hoge','database':'hoge'}
|
|
@@ -78,15 +92,7 @@
|
|
|
78
92
|
|
|
79
93
|
|
|
80
94
|
|
|
81
|
-
def on_message(client, userdata, msg): # イベントドリブン
|
|
82
95
|
|
|
83
|
-
sql = "INSERT INTO event (topic) value ('{0}')".format(msg.topic)
|
|
84
|
-
|
|
85
|
-
cur = conn.cursor()
|
|
86
|
-
|
|
87
|
-
cur.execute(sql)
|
|
88
|
-
|
|
89
|
-
cur.close()
|
|
90
96
|
|
|
91
97
|
```
|
|
92
98
|
|