Đồng bộ hóa vai trò của Azure

Question

Tôi đã tự hỏi về các phương pháp hay nhất trong việc đồng bộ hóa nhiều cá thể xanh chạy cùng một vai trò. Chính xác hơn, tôi muốn ngăn một số vai trò công nhân làm việc trên cùng một đơn vị công việc.

Hàng đợi Azure dường như không giúp ích gì cho vấn đề này. Một tùy chọn là sử dụng bảng sql có khóa và các thủ tục được lưu trữ; nhưng sử dụng đồng bộ hóa sql trong Azure có vẻ hơi khó xử.

Bất kỳ ý tưởng nào?

Chỉnh sửa, chi tiết (nhưng đơn giản hóa vấn đề) của tôi là như sau:

• Có n mục tiêu.
• Một đơn vị công việc phải được thực hiện trên mỗi mục tiêu tại một khoảng thời gian cụ thể (nói 30 giây - nhưng nó khác nhau đối với từng mục tiêu).
• Tôi có m công nhân (được lưu trữ trong h trường hợp).
• Xử lý một đơn vị công việc có thể mất từ ​​10 giây đến 1 giờ.

Ý tưởng là tôi có một scheduler mà đặt đơn vị làm việc trong một hàng đợi Azure, và mỗi m công nhân sẽ đọc những điều này và xử lý chúng.

Vấn đề:

• worker1 bắt đầu làm việc trên unit1 (được liên quan đến target1) - một trong những điều này sẽ mất nhiều thời gian, nói 10 phút
• 30 giây trôi qua
• sự công cụ lập lịch biểu đặt một đơn vị công việc khác cho target1, nói unit13
• worker2 bắt đầu làm việc trên unit13, so với cùng target1 - không tốt

Tôi có một số ý tưởng, nhưng họ không có vẻ mây đủ, vì vậy tôi đang quan tâm đến xem bạn sẽ áp dụng giải pháp nào cho vấn đề này.

Answer 1

Tôi vừa mới viết một vài bài đăng trên blog về việc sử dụng blob cho thuê để thực hiện việc này. Xem http://blog.smarx.com/posts/managing-concurrency-in-windows-azure-with-leases và http://blog.smarx.com/posts/building-a-task-scheduler-in-windows-azure.

Answer 2

dunnry là spot-on: hàng đợi hoạt động tốt để ngăn không cho nhiều trường hợp hoạt động trên cùng một mục công việc. Khi bạn gọi GetMessage, tin nhắn bạn truy xuất hiện không hiển thị cho khoảng thời gian bạn chỉ định (mặc định: 30 giây). Trong khoảng thời gian đó, không người đọc nào khác có thể truy xuất thông điệp xếp hàng này.

Có nói rằng: Bạn cần đảm bảo quá trình xử lý của bạn là không cần thiết. Trong trường hợp quá trình xử lý của bạn mất nhiều thời gian hơn khoảng thời gian ẩn danh, thông báo sẽ hiển thị lại. Tại thời điểm này, người đọc ban đầu không thể xóa tin nhắn, và một số người đọc khác có thể đọc tin nhắn (làm cho nó một lần nữa vô hình).Trong trường hợp này, có thể bạn xử lý lại cùng một thông báo. Bạn sẽ cần phải cẩn thận đặt thời gian chờ của bạn để tránh điều này như một quy tắc chung.

Lưu ý: Mỗi CloudQueueMessage có thuộc tính DequeueCount, vì vậy bạn có thể xác định xem thư có được xem nhiều lần không (và vì vậy bạn cũng có thể xử lý thư độc).

Answer 3

CloudFX có lớp PrimaryInstanceManager có thể được sử dụng cho một số trường hợp này.