Python使用redis发布订阅时，监听频道时出现的问题？【一句话描述不清楚，请各位细看内容】

Python018

Python使用redis发布订阅时，监听频道时出现的问题？【一句话描述不清楚，请各位细看内容】,第1张

上面报的是语法错误，但是东西是别人的写的，因此没办法改，把 python 升级一下，因为低版本的python 可能与高版本的redis 不兼容，你用的redis是2.8.0 建议升到python 3.0左右

DataTable dt = new DataTable()

dt.Columns.Add(new DataColumn("PreRevDate0", typeof(decimal)))

DataColumn col = new DataColumn()

col.ColumnName = "PreRevDate1"

col.Expression = "ABS(Convert.ToInt32(PreRevDate0))"

col.DataType = typeof(decimal)

dt.Columns.Add(col)

DataRow dr = dt.NewRow()

dr["PreRevDate0"] = -1

dt.Rows.Add(dr)

连接调用connect接口，然后调用loop_forever后就开始跑了

connect的第三个参数为mqtt的心跳时间

on_connect 和 on_disconnect 为连接成功和断开的回掉函数，

添加证书，只需要在调用connect函数之前，添加下面两条内容即可。

设置账号密码，在调用connect函数之前，添加下面一条内容即可。

设置WILL主题，在调用connect函数之前，使用will_set接口设置，添加will主题和will主题的payload

主题的订阅使用subscribe接口，一般在on_connect回调函数里面设置

订阅完主题，我们的目的就是要收到订阅的数据，所以需要设置接收数据的回调函数on_message

，只要有数据发送过来on_message就会收到。

发布使用publish接口，如下