Merge pull request #32925 from ankush/view_log_defer
perf: defer view log and enhance flushing
This commit is contained in:
commit
f8a6cf8995
2 changed files with 7 additions and 5 deletions
|
|
@ -31,7 +31,7 @@ def save_to_db():
|
|||
record_count = 0
|
||||
queue_key = get_key_name(key)
|
||||
doctype = get_doctype_name(key)
|
||||
while frappe.cache.llen(queue_key) > 0 and record_count <= 500:
|
||||
while frappe.cache.llen(queue_key) > 0 and record_count <= 10000:
|
||||
records = frappe.cache.lpop(queue_key)
|
||||
records = json.loads(records.decode("utf-8"))
|
||||
if isinstance(records, dict):
|
||||
|
|
@ -41,6 +41,11 @@ def save_to_db():
|
|||
for record in records:
|
||||
record_count += 1
|
||||
insert_record(record, doctype)
|
||||
if record_count % 100 == 0:
|
||||
frappe.db.commit()
|
||||
|
||||
if record_count % 100 == 0:
|
||||
frappe.db.commit()
|
||||
|
||||
|
||||
def insert_record(record: Union[dict, "Document"], doctype: str):
|
||||
|
|
|
|||
|
|
@ -93,10 +93,7 @@ def make_view_log(
|
|||
view.visitor_id = visitor_id
|
||||
|
||||
try:
|
||||
if frappe.flags.read_only:
|
||||
view.deferred_insert()
|
||||
else:
|
||||
view.insert(ignore_permissions=True)
|
||||
view.deferred_insert()
|
||||
except Exception:
|
||||
frappe.clear_last_message()
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue