0

我编写了一个小脚本，它迭代社交网络中的提要并在另一个社交网络中发布尚未发布的帖子。我分两步完成：首先我阅读了第一个社交网络的提要，并将每篇文章都放入我的数据库中，包括一个“已发布”布尔值。其次，我浏览了我的数据库中所有已发布的布尔值设置为 false 的条目，并在第二个社交网络上发布了消息。我使用数据集库连接到我的本地 SQLite 数据库。现在的问题是：第一步一切正常。在第二步中，我将提到的布尔值设置为 false 来迭代数据库条目，将条目发布到第二个社交网络，然后我想更新我的数据库中的布尔值。问题就在这里：更新只工作一次，然后我收到以下错误：

Traceback (most recent call last):
  File "xy.py", line 56, in <module>
    table.update(data, ['sc_id'])
  File "/Users/.../lib/python2.7/site-packages/dataset/persistence/table.py", line 137, in update
    rp = self.database.executable.execute(stmt)
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 1752, in execute
    return connection.execute(statement, *multiparams, **params)
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 729, in execute
    return meth(self, multiparams, params)
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/sql/elements.py", line 321, in _execute_on_connection
    return connection._execute_clauseelement(self, multiparams, params)
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 826, in _execute_clauseelement
    compiled_sql, distilled_params
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 997, in _execute_context
    self._commit_impl(autocommit=True)
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 530, in _commit_impl
    self.connection._reset_agent is self.__transaction:
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 236, in connection
    return self._revalidate_connection()
  File "/Users/.../lib/python2.7/site-packages/sqlalchemy/engine/base.py", line 247, in _revalidate_connection
    raise exc.ResourceClosedError("This Connection is closed")
sqlalchemy.exc.ResourceClosedError: This Connection is closed

这是我更新数据库字段的方式（根据数据集文档）：

unpublished_messages = table.find(published = False)
for posting in unpublished_messages:
    # here i post to the second social network...
    data = dict(sc_id = posting['sc_id'], published = True)
    table.update(data, ['sc_id'])

它在第一步工作得很好，在第二步迭代数据库条目时工作一次，但在第二次循环迭代时它在 table.update... 行崩溃。

我完全不明白发生了什么。

4

1 回答 1

0

不知何故，无法遍历 ResultIter ('unpublished_messages') 并在同一步骤中修改表。我通过遍历 ResultIter 并将元素放入一个普通的 python 列表中解决了这个问题。然后我迭代了列表并更新了表格。

于 2014-10-22T13:56:16.757 回答