通知APIでQueue ストレージを利用する
まず、Media Service の通知結果を格納するためのストレージサービスを作成する。同ストレージサービスは Media Service にアタッチされているものでも構わない。以下に実行結果も含めたスクリーンキャプチャなので、構成の参考にしてほしい。
次に、Media Service SDK .NET版を利用した以下の様なC#コード（抜粋で恐縮だが）を作成する。
private static IJob EncodeToMp4(CloudMediaContext context, string inputAssetId)
{
var inputAsset = context.Assets.Where(a => a.Id == inputAssetId).FirstOrDefault();
if (inputAsset == null)
throw new ArgumentException("Could not find assetId: " + inputAssetId);
var encodingPreset = "H264 Adaptive Bitrate MP4 Set SD 16x9";
IJob job = context.Jobs.Create("Encoding " + inputAsset.Name + " to " + encodingPreset);
INotificationEndPoint notificationEndPoint = context.NotificationEndPoints.Create(
Guid.NewGuid().ToString(), NotificationEndPointType.AzureQueue, "myqueue");
job.JobNotificationSubscriptions.AddNew(NotificationJobState.All, notificationEndPoint);
IMediaProcessor latestWameMediaProcessor = (from p in context.MediaProcessors where p.Name == "Windows Azure Media Encoder" select p).ToList()
.OrderBy(wame => new Version(wame.Version)).LastOrDefault();
ITask encodeTask = job.Tasks.AddNew("Encoding", latestWameMediaProcessor, encodingPreset, TaskOptions.None);
encodeTask.InputAssets.Add(inputAsset);
encodeTask.OutputAssets.AddNew(inputAsset.Name + " as " + encodingPreset, AssetCreationOptions.None);
job.StateChanged += new EventHandler<JobStateChangedEventArgs>(JobStateChanged);
job.Submit();
job.GetExecutionProgressTask(CancellationToken.None).Wait();
return job;
}
現時点では NotificationEndPointType.AzureQueue しか通知の方法が用意されていないが、今後は通知方法の拡張が期待される。また、通知情報は"完了時のみ（NotificationJobState.FinalStatesOnly）" or "イベント毎の通知（NotificationJobState.All）" or "通知しない（NotificationJobState.None）" を選択が可能だ。
上記のコードを含めた処理を実行した結果、以下のJSON形式の文字列がQueueストレージに格納される。「1.登録 → 2.スケジュール → 3.処理中 → 4.完了」の流れが格納されていることが確認できる。
{"MessageVersion":"1.0","EventType":"NotificationEndPointRegistration","ETag":"a756c1f67e96d95273e38e5e5e918a77cbef37bdfaded6069eb0a8bd800bae81","TimeStamp":"2013-07-21T02:08:04","Properties":{"NotificationEndPointId":"nb:nepid:UUID:4e4199b8-3db1-43ea-851b-95576d17e60b","State":"Registered","Name":"8822be8d-2791-4ad0-a991-54ef1b74388a","Created":"2013-07-21T02:08:01"}}
{"MessageVersion":"1.0","EventType":"JobStateChange","ETag":"f9cb50428bc9927d4f637d8efe9a82aa3de0c65ded214cde17ef378d5388e218","TimeStamp":"2013-07-21T02:08:17","Properties":{"JobId":"nb:jid:UUID:10a68b86-fe65-b943-bd2d-6ad2ba1cd3aa","JobName":"Encoding azure to H264 Adaptive Bitrate MP4 Set SD 16x9","NewState":"Scheduled","OldState":"Queued","AccountName":"xxxxxxxxxxxxxxxxxxx"}}
{"MessageVersion":"1.0","EventType":"JobStateChange","ETag":"b70613d1c78821f96a05bda3c7ec16623424441ecd37b0b9417cbaa70761faab","TimeStamp":"2013-07-21T02:08:22","Properties":{"JobId":"nb:jid:UUID:10a68b86-fe65-b943-bd2d-6ad2ba1cd3aa","JobName":"Encoding azure to H264 Adaptive Bitrate MP4 Set SD 16x9","NewState":"Processing","OldState":"Scheduled","AccountName":"xxxxxxxxxxxxxxxxxxx"}}
{"MessageVersion":"1.0","EventType":"JobStateChange","ETag":"74830e61be956a9c7566585d09dec148365806b42b9813405d4f97a1e1b3861a","TimeStamp":"2013-07-21T02:09:36","Properties":{"JobId":"nb:jid:UUID:10a68b86-fe65-b943-bd2d-6ad2ba1cd3aa","JobName":"Encoding azure to H264 Adaptive Bitrate MP4 Set SD 16x9","NewState":"Finished","OldState":"Processing","AccountName":"xxxxxxxxxxxxxxxxxxx"}}下記のJSONオブジェクトを利用する場合は個別にクラスを作成する必要があるので、以下どちらかの手法を利用してほしい。
また、キューストレージのエンドポイントが不正な形式の場合、以下のレスポンスが帰ってくるので参考にしてほしい。
"<?xml version=\"1.0\" encoding=\"utf-8\"?><m:error xmlns:m=\"http://schemas.microsoft.com/ado/2007/08/dataservices/metadata\"><m:code /><m:message xml:lang=\"en-US\">NotificationEndPoint.EndPointAddress must match rules described in http://msdn.microsoft.com/en-us/library/windowsazure/dd179349.aspx</m:message></m:error>"
