データベース内のいくつかのテーブルは、バックグラウンドで常に実行されている (データ マイニングを行っている) いくつかのバックグラウンド python スクリプトから更新されます。Django は、データが Django の外部で更新され、常に古いデータを表示していることを知るのに苦労していました。長い間調査した結果、オンラインでキャッシュを無効にする方法のほとんどは機能しませんが、この回避策は完全に機能します。
from django.db import connection
connection.close()
これはまだ完全な解決策ではありませんが、Django の見解では機能します。それを修正する方法を知っている場合は、ここDjango: how to refresh models or reload models from database にコメントしてください。ただし、データは REST からもアクセスされます。Tastypie では、リソースはまだ更新されていません。
JSON 構造は常に古いタイムスタンプを返し、データベースの最新の値が異なることがわかります。私はすでに次のことを試しましたが、うまくいきませんでした。
from tastypie.cache import NoCache
cache = NoCache()
現在更新する唯一の方法は、uwsgi サービスを手動で再起動することですが、これは明らかに解決策ではありません。この問題は私を夢中にさせています。どんなコメントでも大歓迎です。ありがとうございました。
アップデート
コードとモデルを単純化して、タイムスタンプ列のみを含めました。完全なコードとログは次のとおりです。
Tastypie の resources.py
from lp.models import LatestPrices
from tastypie.resources import ModelResource
from tastypie.serializers import Serializer
from django.db import connection
class LpResource(ModelResource):
class Meta:
# forces Django to make a new connection, fixes OperationalError: (2006, 'MySQL server has gone away') after a long time with no access
connection.close()
queryset = LatestPrices.objects.all()
include_resource_uri = False
resource_name = 'lp'
allowed_methods = ['get']
excludes = ['slug']
serializer = Serializer(formats=['json'])
connection.close()
models.py :
from django.db import models
class LatestPrices(models.Model):
id = models.AutoField(primary_key=True)
slug = models.SlugField(unique=True)
# timestamp is updated every 10 seconds
timestamp = models.DateTimeField(null=True, blank=True)
# Removed all other columns for debugging.
# The data to show in admin
def __unicode__(self):
return str(self.timestamp)
class Meta:
db_table = 'latest_prices'
Django 外の DB インジェクター スクリプト
while True:
try:
# Get date & time
timestamp = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
logger.info("------" + timestamp)
# Inject to local database
logger.debug("Injecting...")
con = None
con = db.connect('localhost', 'user', 'pw', 'tablename')
con.autocommit(True)
cursor = con.cursor(MySQLdb.cursors.DictCursor)
update_query = "UPDATE latest_prices SET slug='latest', timestamp='" + timestamp \
+ "' WHERE id=1"
rows_affected = cursor.execute(update_query)
con.commit()
if rows_affected != 1:
logger.critical("Couldn't inject! Rows affected: " + str(rows_affected))
cursor.close()
time.sleep(WAIT_TIME)
continue
cursor.close()
except Exception as e:
# Code removed. Email admin the error string...
pass
finally:
pass
time.sleep(WAIT_TIME)
mysql.log
124 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:38:16' WHERE id=1
124 Query commit
130404 18:38:26 125 Connect dev@localhost on gs
125 Query set autocommit=0
125 Query set autocommit=1
124 Quit
125 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:38:26' WHERE id=1
125 Query commit
130404 18:38:36 126 Connect dev@localhost on gs
126 Query set autocommit=0
126 Query set autocommit=1
125 Quit
126 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:38:36' WHERE id=1
126 Query commit
130404 18:38:46 127 Connect dev@localhost on gs
127 Query set autocommit=0
127 Query set autocommit=1
126 Quit
127 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:38:46' WHERE id=1
127 Query commit
# Click the browser refresh button one time here
130404 18:38:53 73 Query SELECT `latest_prices`.`id`, `latest_prices`.`slug`, `latest_prices`.`timestamp` FROM `latest_prices` WHERE (`latest_prices`.`id` = 1 AND `latest_prices`.`id` = 1 )
130404 18:38:56 128 Connect dev@localhost on gs
128 Query set autocommit=0
128 Query set autocommit=1
127 Quit
128 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:38:56' WHERE id=1
128 Query commit
# Click the browser refresh button a few times here
130404 18:38:58 70 Query SELECT `latest_prices`.`id`, `latest_prices`.`slug`, `latest_prices`.`timestamp` FROM `latest_prices` WHERE (`latest_prices`.`id` = 1 AND `latest_prices`.`id` = 1 )
130404 18:39:02 70 Query SELECT `latest_prices`.`id`, `latest_prices`.`slug`, `latest_prices`.`timestamp` FROM `latest_prices` WHERE (`latest_prices`.`id` = 1 AND `latest_prices`.`id` = 1 )
130404 18:39:04 73 Query SELECT `latest_prices`.`id`, `latest_prices`.`slug`, `latest_prices`.`timestamp` FROM `latest_prices` WHERE (`latest_prices`.`id` = 1 AND `latest_prices`.`id` = 1 )
130404 18:39:06 129 Connect dev@localhost on gs
129 Query set autocommit=0
129 Query set autocommit=1
128 Quit
129 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:39:06' WHERE id=1
129 Query commit
130404 18:39:16 130 Connect dev@localhost on gs
130 Query set autocommit=0
130 Query set autocommit=1
130 Query UPDATE latest_prices SET slug='latest', timestamp='2013-04-04 18:39:16' WHERE id=1
129 Quit
130 Query commit
ブラウザ出力 (常に同じもの)
{"id": 1, "timestamp": "2013-04-04T18:29:45"}
HTTP ヘッダー
Cache-Control →no-cache
Connection →keep-alive
Content-Type →application/json
Date →Fri, 05 Apr 2013 00:27:48 GMT
Server →nginx
Transfer-Encoding →
Transfer-Encoding
The form of encoding used to safely transfer the entity to the user. Currently defined methods are: chunked, compress, deflate, gzip, identity.
chunked
Vary →Accept
また、インジェクター スクリプトに明示的なコミットを追加しました。私が使用していた既存の「set autocommit = 1」と一緒に、mysql.logにcommitと書かれていることに大きな違いはありませんでした。
mysql.log を見ると、ブラウザーの更新ボタンを押すたびに、Django から送信された新しい SELECT ステートメントが表示されます。しかし、オブジェクトはまだ古いです。わからない、なぜ？