All Products
Search
Document Center

Batch Compute (Deprecated):Notifikasi

Last Updated:Jul 02, 2025

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.

  1. Aktifkan layanan pesan.

  2. Buat topik MNS.

  3. Buat langganan topik MNS.

  4. Otorisasi dorongan pesan Batch Compute.

  5. Masuk ke konsol untuk menyelesaikan otorisasi satu klik. Jika Anda belum menyelesaikan otorisasi, konsol akan menampilkan pesan berikut:

Console

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"
}