Cập nhật hàng loạt trong Google App Engine Datastore

Question

Cách thích hợp để thực hiện cập nhật hàng loạt trên thực thể trong kho dữ liệu của Máy ứng dụng của Google là gì? Nó có thể được thực hiện mà không cần phải lấy các thực thể?

Ví dụ, những gì sẽ là GAE equivilant một cái gì đó như thế này trong SQL:

UPDATE dbo.authors 
SET city = replace(city, 'Salt', 'Olympic') 
WHERE city LIKE 'Salt%'; 

Answer 1

Không có một bản dịch trực tiếp. Kho dữ liệu thực sự không có khái niệm cập nhật; tất cả những gì bạn có thể làm là ghi đè các thực thể cũ với một thực thể mới tại cùng một địa chỉ (khóa). Để thay đổi một thực thể, bạn phải lấy nó từ kho dữ liệu, sửa đổi nó cục bộ, và sau đó lưu nó trở lại.

Cũng không tương đương với toán tử LIKE. Trong khi kết hợp ký tự đại diện là có thể với một số thủ thuật, nếu bạn muốn kết hợp '% Salt%' bạn phải đọc từng thực thể duy nhất vào bộ nhớ và thực hiện so sánh chuỗi cục bộ.

Vì vậy, nó sẽ không hoàn toàn sạch sẽ hoặc hiệu quả như SQL. Đây là một sự cân bằng với hầu hết các cửa hàng đối tượng phân tán, và kho dữ liệu cũng không ngoại lệ.

Điều đó nói rằng, the mapper library có sẵn để tạo điều kiện cập nhật hàng loạt như vậy. Thực hiện theo ví dụ và sử dụng một cái gì đó như thế này cho hàm process của bạn:

def process(entity): 
    if entity.city.startswith('Salt'): 
    entity.city = entity.city.replace('Salt', 'Olympic') 
    yield op.db.Put(entity) 

Có các lựa chọn thay thế khác ngoài công cụ lập bản đồ. Mẹo tối ưu hóa quan trọng nhất là cập nhật hàng loạt các bản cập nhật của bạn; không lưu lại từng thực thể được cập nhật riêng lẻ. Nếu bạn sử dụng trình đặt bản đồ và sản lượng, điều này sẽ được xử lý tự động.

Answer 2

bạn có thể sử dụng lớp truy vấn, http://code.google.com/appengine/docs/python/datastore/queryclass.html

query = authors.all().filter('city >', 'Salt').fetch() 
for record in query: 
    record.city = record.city.replace('Salt','Olympic') 

Answer 3

Không, nó không thể được thực hiện mà không lấy các thực thể.

Không có điều gì như 'giới hạn kỷ lục tối đa 1000', nhưng tất nhiên là có thời gian chờ trên bất kỳ yêu cầu nào - và nếu bạn có số lượng lớn thực thể cần sửa đổi, một lần lặp đơn giản có thể sẽ bị lỗi. Bạn có thể quản lý điều này bằng cách chia nhỏ nó thành nhiều hoạt động và theo dõi với query cursor hoặc có khả năng bằng cách sử dụng MapReduce framework.