Python

Question

我有一个访问 SQlite 数据库的 slack 机器人。当我运行机器人在前台时，一切正常，但是当我运行它作为守护进程时，它似乎连接到我的数据库，但随后 returns "table not found" 每次查询我运行.

问题是，这在我的最新版本之前一直有效，但我找不到有什么变化，所以我制作了一个精简版作为测试，但我仍然遇到同样的问题。见下文：

import syslog
import sqlite3
import os
from daemonize import Daemonize
from slackclient import SlackClient
from qatoken import token

#Slack vars
nickname = "NetBot-QA"
dump = "#net-dump-qa"
channel = "#net-alerts-qa"
avatar = ":loader:"

#Daemonize vars
pid = "/tmp/netbot-qa.pid"
app = "net-bot-qa"
syslog.openlog('netbot', 0, syslog.LOG_LOCAL4 )

###################################################### MAIN
def main():

    sc = SlackClient(token)
    sc.api_call("chat.postMessage", username=nickname, channel=dump, text="{0}/net-alerts-test.db".format(os.path.dirname(__file__)), icon_emoji=avatar)

    try:
        conn = sqlite3.connect("{0}/net-alerts-test.db".format(os.path.dirname(__file__)))
        c = conn.cursor()
        c.execute("SELECT * from maint_calendar")
        sc.api_call("chat.postMessage", username=nickname, channel=dump, text="made it!", icon_emoji=avatar)
    except (SystemExit, KeyboardInterrupt):
        raise
    except Exception, e:
        sc.api_call("chat.postMessage", username=nickname, channel=dump, text="The bot crashed", icon_emoji=avatar)
        syslog.syslog("error: {0}".format(e))

########################################################################################
#main()
########################################################################################
#main()
daemon = Daemonize(app=app, pid=pid, action=main)
daemon.start()

如果我运行 main()，我会收到松弛消息 "Made it!"，但如果我将其注释掉并改为运行 daemon.start()，我会得到"The bot crashed".

当我 cat /var/log/messages 时，这是我看到的：

Nov 16 09:47:37 server1 netbot: error: no such table: maint_calendar

[root@server1 net-alerts]# pwd
/opt/bots/net-alerts

[root@server1 net-alerts]# sqlite3 net-alerts-test.db
SQLite version 3.7.17 2013-05-20 00:56:22
sqlite> .schema
CREATE TABLE maint_calendar (start time, finish time, summary text, dc_tag text, provider text, CONSTRAINT start_sum PRIMARY KEY (start, summary));

我也尝试过运行使用数据库的静态路径对此进行设置，但 os.path.dirname 与我使用的所有其他脚本配合得很好。我发现另一个 post 说你必须在守护程序上下文 (main()) 中建立数据库连接，但我从一开始就一直这样做。我运行没主意了。

Answer 1

在我看来，这一行：

conn = sqlite3.connect("{0}/net-alerts-test.db".format(os.path.dirname(__file__)))

实际上是连接到两个不同的来源，这取决于你是守护进程还是只是运行 main()。

只需将文件保存到全局变量中的db，稍后使用。例如：

DB_PATH = "{0}/net-alerts-test.db".format(os.path.dirname(__file__))
...
def main():

    sc = SlackClient(token)
    sc.api_call("chat.postMessage", username=nickname, channel=dump, text="{0}/net-alerts-test.db".format(os.path.dirname(__file__)), icon_emoji=avatar)

    try:
        conn = sqlite3.connect(DB_PATH)

Answer 2

我遇到了同样的问题。我已经硬编码了 DB 文件的完整路径并且它工作得很好！

示例：

dbconn = sqlite3.connect("/home/pi/db.db")
cur = dbconn.cursor()
cur.execute("INSERT INTO raw_data(id, packet, db_insert_time, sync) VALUES(NULL, ?, ?, ?)", ('Line', x, 'N'))

dbconn.commit()
print('DB Insert success!')

Python - Table 将 SQlite3 与 Daemonize 一起使用时未发现错误

Python - Table not found error when using SQlite3 with Daemonize

sqlite

python-daemon