This template creates a Logic app that listens to an onedrive folder and will copy it to an Azure Media Services asset, triggers an encoding job, publish the output asset and send an email when the process is complete.
See the detailed view of the logic app.
If not already done : fork the repo, deploy Azure Functions and select the "media-functions-for-logic-app" Project (IMPORTANT!)
Follow the guidelines in the git tutorial for details on how to fork the project and use Git properly with this project.
Note : if you never provided your GitHub account in the Azure portal before, the continous integration probably will probably fail and you won't see the functions. In that case, you need to setup it manually. Go to your azure functions deployment / Functions app settings / Configure continous integration. Select GitHub as a source and configure it to use your fork.
It is recommended to use the same resource group for the functions and the logic app. The functions and Logic App must be deployed in the same region. Please specify the name of the storage account used by Media Services.
When deployed, go to the Logic App Designer and fix the connections (Onedrive, Outlook.com...). Make sure to (re)select the OneDrive folder that you want to use for the ingest.
To enable streaming, go to the Azure portal, select the Azure Media Services account which as been created, and start the default streaming endpoint.
This template creates a Logic app which
- listens to an onedrive folder,
- copy it to an Azure Media Services asset,
- triggers an encoding job,
- converts the English audio to text (using Media Indexer v2),
- translates the English subtitles to French (using Bing translator),
- copies back the French subtitles to the subtitles asset,
- publishes the output assets,
- generates a short playback URL (using bitlink)
- sends an email with Office365 when the process is complete or if the job failed. In the email, the playback link includes the two subtitles.
This section list the functions available and describes the input and output parameters.
This function creates an empty asset.
Input:
{
"assetName" : "the name of the asset"
}
Output:
{
"assetId" : "the Id of the asset created",
"containerPath" : "the url to the storage container of the asset"
}This function create the asset files based on the blobs in the asset container.
Input:
{
"assetId" : "the Id of the asset"
}This function submits a job wth encoding and/or analytics.
Input:
{
"assetId" : "nb:cid:UUID:2d0d78a2-685a-4b14-9cf0-9afb0bb5dbfc", // Mandatory, Id of the source asset
"mesPreset" : "Adaptive Streaming", // Optional but required to encode with Media Encoder Standard (MES). If mesPreset contains an extension "H264 Multiple Bitrate 720p with thumbnail.json" then it loads this file from ..\Presets
"workflowAssetId" : "nb:cid:UUID:2d0d78a2-685a-4b14-9cf0-9afb0bb5dbfc", // Optional, but required to encode the asset with Premium Workflow Encoder. Id for the workflow asset
"indexV1Language" : "English", // Optional but required to index the asset with Indexer v1
"indexV2Language" : "EnUs", // Optional but required to index the asset with Indexer v2
"ocrLanguage" : "AutoDetect" or "English", // Optional but required to do OCR
"faceDetectionMode" : "PerFaceEmotion, // Optional but required to trigger face detection
"faceRedactionMode" : "analyze", // Optional, but required for face redaction
"motionDetectionLevel" : "medium", // Optional, required for motion detection
"summarizationDuration" : "0.0", // Optional. Required to create video summarization. "0.0" for automatic
"hyperlapseSpeed" : "8", // Optional, required to hyperlapse the video
"priority" : 10, // Optional, priority of the job
"useEncoderOutputForAnalytics" : true // Optional, use generated asset by MES or Premium Workflow as a source for media analytics (except hyperlapse)
}
Output:
{
"jobId" : // job id
"mes" : // Output asset generated by MES (if mesPreset was specified)
{
assetId : "",
taskId : ""
},
"mepw" : // Output asset generated by Premium Workflow Encoder
{
assetId : "",
taskId : ""
},
"indexV1" : // Output asset generated by Indexer v1
{
assetId : "",
taskId : "",
language : ""
},
"indexV2" : // Output asset generated by Indexer v2
{
assetId : "",
taskId : "",
language : ""
},
"ocr" : // Output asset generated by OCR
{
assetId : "",
taskId : ""
},
"faceDetection" : // Output asset generated by Face detection
{
assetId : ""
taskId : ""
},
"faceRedaction" : // Output asset generated by Face redaction
{
assetId : ""
taskId : ""
},
"motionDetection" : // Output asset generated by motion detection
{
assetId : "",
taskId : ""
},
"summarization" : // Output asset generated by video summarization
{
assetId : "",
taskId : ""
},
"hyperlapse" : // Output asset generated by Hyperlapse
{
assetId : "",
taskId : ""
}
}This function chevck a job status.
Input:
{
"jobId" : "nb:jid:UUID:1ceaa82f-2607-4df9-b034-cd730dad7097", // Mandatory, Id of the source asset
"extendedInfo" : true // optional. Returns ams account unit size, nb units, nb of jobs in queue, scheduled and running states. Only if job is complete or error
}
Output:
{
"jobState" : 2, // The state of the job (int)
"isRunning" : "False", // True if job is running
"isSuccessful" : "True", // True is job is a success. Only valid if IsRunning = False
"errorText" : "" // error(s) text if job state is error
"startTime" :""
"endTime" : "",
"runningDuration" : ""
"extendedInfo" : // if extendedInfo is true and job is finished or in error
{
mediaUnitNumber = 2,
mediaUnitSize = "S2",
otherJobsProcessing = 2;
otherJobsScheduled = 1;
otherJobsQueue = 1;
}
}This function chevck a task status.
Input:
{
"jobId" : "nb:jid:UUID:1ceaa82f-2607-4df9-b034-cd730dad7097", // Mandatory, Id of the job
"taskId" : "nb:tid:UUID:cdc25b10-3ed7-4005-bcf9-6222b35b5be3", // Mandatory, Id of the task
"extendedInfo" : true // optional. Returns ams account unit size, nb units, nb of jobs in queue, scheduled and running states. Only if job is complete or error
}
Output:
{
"taskState" : 2, // The state of the task (int)
"isRunning" : "False", // True if job is running
"isSuccessful" : "True", // True is job is a success. Only valid if IsRunning = False
"errorText" : "" // error(s) text if task state is error
"startTime" :""
"endTime" : "",
"runningDuration" : ""
"extendedInfo" : // if extendedInfo is true and job is finished or in error
{
mediaUnitNumber = 2,
mediaUnitSize = "S2",
otherJobsProcessing = 2;
otherJobsScheduled = 1;
otherJobsQueue = 1;
}
}This function publishes an asset.
Input:
{
"assetId" : "nb:cid:UUID:2d0d78a2-685a-4b14-9cf0-9afb0bb5dbfc", // Mandatory, Id of the source asset
}
Output:
{
playerUrl : "", // Url of demo AMP with content
smoothUrl : "", // Url for the published asset (contains name.ism/manifest at the end) for dynamic packaging
pathUrl : "" // Url of the asset (path)
}This function returns subtitles from an asset.
Input:
{
"assetId" : "nb:cid:UUID:88432c30-cb4a-4496-88c2-b2a05ce9033b", // Mandatory, Id of the source asset
"timeOffset" :"00:01:00", // optional, offset to add to subtitles (used for live analytics)
"deleteAsset" : true // Optional, delete the asset once data has been read from it
}
Output:
{
"vttUrl" : "", // the full path to vtt file if asset is published
"ttmlUrl" : "", // the full path to vtt file if asset is published
"pathUrl" : "", // the path to the asset if asset is published
"vttDocument" : "", // the full vtt document,
"vttDocumentOffset" : "", // the full vtt document with offset
"ttmlDocument : "" // the full ttml document
"ttmlDocumentOffset : "" // the full ttml document with offset
}This function adds a text file to an existing asset. As a option, the text can be converted from ttml to vtt (useful when the ttml has been translated with MS Translator and the user wants a VTT file for Azure Media Player).
Input:
{
"document" : "", // content of the text file to create
"fileName" : "subtitle-en.ttml", // file name to create
"assetId" : "nb:cid:UUID:88432c30-cb4a-4496-88c2-b2a05ce9033b", // Mandatory, Id of the asset
"convertTtml" :true // optional, convert the document from ttml to vtt, and create another file in the asset : subtitle-en.vtt
}
Output:
{
}This function delete AMS entities like job(s) and/or asset(s). Several asset ids or job ids can be passed (with a coma separator).
Input:
{
"jobID": "nb:jid:UUID:7f566f5e-be9c-434f-bb7b-101b2e24f27e,nb:jid:UUID:58f9e85a-a889-4205-baa1-ecf729f9c753", // job(s) id. Coma delimited if several job ids
"assetId" : "nb:cid:UUID:61926f1d-69ba-4386-a90e-e27803104853,nb:cid:UUID:b4668bc4-2899-4247-b339-429025153ab9" // asset(s) id.
}
Output:
{
}This function sets the number and speed of media reserved units in the account.
Input:
{
"ruCount" : "+1", // can be a number like "1", or a number with + or - to increase or decrease the number. Example : "+2" or "-3"
"ruSpeed" : "S1" // can be "S1", "S2" or "S3"
}
Output:
{
"success" : "True", // return if operation is a success or not
"maxRu" : 10, // number of max units
"newRuCount" : 3, // new count of units
"newRuSpeed" : "S2" // new speed of units
}This function submits a job to process a live stream with media analytics. The first task is a subclipping task that createq a MP4 file, then media analytics are processed on this asset.
Input:
{
"channelName": "channel1", // Mandatory
"programName" : "program1", // Mandatory
"intervalSec" : 60 // Optional. Default is 60 seconds. The duration of subclip (and interval between two calls)
"indexV1Language" : "English", // Optional
"indexV2Language" : "EnUs", // Optional
"ocrLanguage" : "AutoDetect" or "English", // Optional
"faceDetectionMode" : "PerFaceEmotion, // Optional
"faceRedactionMode" : "analyze", // Optional, but required for face redaction
"motionDetectionLevel" : "medium", // Optional
"summarizationDuration" : "0.0", // Optional. 0.0 for automatic
"hyperlapseSpeed" : "8" // Optional
"priority" : 10 // Optional. Priority of the job
}
Output:
{
"triggerStart" : "" // date and time when the function was called
"jobId" : // job id
subclip :
{
assetId : "",
taskId : "",
start : "",
duration : ""
},
indexV1 :
{
assetId : "",
taskId : "",
language : ""
},
indexV2 :
{
assetId : "",
taskId : "",
language : ""
},
ocr :
{
assetId : "",
taskId : ""
},
faceDetection :
{
assetId : ""
taskId : ""
},
faceRedaction :
{
assetId : ""
taskId : ""
},
motionDetection :
{
assetId : "",
taskId : ""
},
summarization :
{
assetId : "",
taskId : ""
},
hyperlapse :
{
assetId : "",
taskId : ""
},
"programId" = programid,
"channelName" : "",
"programName" : "",
"programUrl":""
}