Layanan Batch Compute mengirimkan pesan notifikasi berdasarkan topik yang disediakan oleh MNS. Anda dapat membuat, mengelola, dan berlangganan ke topik, serta menentukan konfigurasi topik saat menggunakan Batch Compute untuk membuat kluster atau mengirimkan pekerjaan. Batch Compute akan mendorong pesan ke topik yang telah ditentukan sesuai dengan konfigurasi tersebut. Anda dapat menetapkan empat metode notifikasi di konsol MNS: URL, antrian MNS, email, dan SMS. Saat ini, Batch Compute mendukung dua jenis peristiwa pesan: peristiwa kluster dan peristiwa pekerjaan.
Buat topik MNS.
Buat langganan topik MNS.
Otorisasi dorongan pesan Batch Compute.
Masuk ke konsol untuk menyelesaikan otorisasi satu klik. Jika Anda belum menyelesaikan otorisasi, konsol akan menampilkan pesan berikut:

Lewati langkah ini jika Anda telah menyelesaikan otorisasi.
2. Penagihan
Biaya layanan pesan ditangani oleh layanan pesan, dan tidak ada biaya tambahan yang dikenakan untuk layanan Batch Compute.
3. Jenis pesan
3.1 Peristiwa kluster
Saat menggunakan SDK atau konsol untuk membuat kluster, Anda dapat mengonfigurasi jenis peristiwa pesan berikut.
{
"Notification": {
"Topic": {
"Name": "test-topic",
"Endpoint": "http://[UserId].mns.[Region].aliyuncs.com/",
"Events": [
"OnClusterDeleted",
"OnInstanceCreated",
"OnInstanceActive"
]
}
}
}Field | Description |
Name | Nama dari topik MNS. |
Endpoint | Titik akhir intranet MNS. Lihat Wilayah dan titik akhir. |
3.2 Peristiwa pekerjaan
Saat menggunakan SDK atau konsol untuk membuat pekerjaan, Anda dapat mengonfigurasi jenis peristiwa pesan berikut.
{
"Notification": {
"Topic": {
"Name": "test-topic",
"Endpoint": "http://[UserId].mns.[Region].aliyuncs.com/",
"Events": [
"OnJobWaiting",
"OnJobRunning",
"OnJobStopped",
"OnJobFinished",
"OnJobFailed",
"OnTaskWaiting",
"OnTaskRunning",
"OnTaskStopped",
"OnTaskFinished",
"OnTaskFailed",
"OnInstanceWaiting",
"OnInstanceRunning",
"OnInstanceStopped",
"OnInstanceFinished",
"OnInstanceFailed",
"OnPriorityChange"
]
}
}
}Field | Description |
Name | Nama dari topik MNS |
Endpoint | Titik akhir intranet MNS. |
4. Format pesan
Saat ini, pesan dikirim dalam format string JSON.
4.1 Peristiwa kluster
Pesan untuk peristiwa OnClusterDeleted.
{
"Category": "Cluster",
"ClusterId": "cls-hr2rbl6qt5gki7392b8001",
"ClusterName": "test-cluster",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"State": "Deleted",
"Event": "OnClusterDeleted"
}Pesan untuk peristiwa OnInstanceCreated atau OnInstanceActive.
{
"Category": "Cluster",
"ClusterId": "cls-hr2rbl6qt5gki7392b8001",
"Group": "group1",
"InstanceId": "i-wz9c51g2s6zsrtnqi4fa",
"InnerIpAddress": "10.45.168.26",
"Hints": "",
"State": "Starting",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"Event": "OnInstanceCreated"
}4.2 Peristiwa pekerjaan
Pesan untuk peristiwa OnJobWaiting, OnJobRunning, OnJobStopped, OnJobFinished, atau OnJobFailed.
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"JobName": "test-job",
"Event": "OnJobWaiting",
"State": "Waiting",
"CreationTime": "2016-11-01T15:25:02.837728Z",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z",
"Message": ""
}Pesan untuk peristiwa OnTaskWaiting, OnTaskRunning, OnTaskStopped, OnTaskFinished, atau OnTaskFailed.
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"Task": "Echo",
"Event": "OnTaskWaiting",
"State": "Waiting",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z"
}Pesan untuk peristiwa OnInstanceWaiting, OnInstanceRunning, OnInstanceStopped, OnInstanceFinished, atau OnInstanceFailed.
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"Task": "Echo",
"InstanceId": "0",
"Event": "OnInstanceWaiting",
"State": "Waiting",
"StartTime": "2016-11-01T15:35:02.837728Z",
"EndTime": "2016-11-01T15:45:02.837728Z",
"RetryCount": "0",
"Progress": "0",
"StdoutRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stderr.job-0000000058184218000008150000000D.task.0",
"StderrRedirectPath": "oss://bucket/tests/a44c0ad8-a003-11e6-8f8e-fefec0a80e06/logs/stdout.job-0000000058184218000008150000000D.task.0",
"ExitCode": "0",
"ErrorCode": "",
"ErrorMessage": "",
"Detail": ""
}Pesan untuk peristiwa OnPriorityChange.
{
"Category": "Job",
"JobId": "job-0000000058524720000077E900007257",
"JobName": "test-job",
"Event": "OnPriorityChange",
"State": "Waiting",
"CreationTime": "2016-11-01T15:45:02.837728Z",
"StartTime": "2016-11-01T15:55:02.837728Z",
"EndTime": "2016-11-01T15:57:02.837728Z",
"Message": "",
"From": "10",
"To": "20"
}