Azure Stream Analytics | TypeScript

View Code Deploy

An example Pulumi program that deploys an Azure Stream Analytics job to transform data in an Event Hub.

Running the App

  1. Create a new stack:

    $ pulumi stack init dev
  2. Login to Azure CLI (you will be prompted to do this during deployment if you forget this step):

    $ az login
  3. Restore NPM dependencies:

    $ npm install
  4. Configure the location to deploy the example to:

    $ pulumi config set azure:location <location>
  5. Run pulumi up to preview and deploy changes:

    $ pulumi up
    Previewing update (dev):
    Updating (dev):
      + 15 created
    Update duration: 2m43s
  6. Use the following sample messages for testing:

    // Inputs (1 line - 1 event):
    // Output:

    You can send a message with a curl command:

    curl -X POST '$(pulumi stack output inputEndpoint)' -H 'Authorization: $(pulumi stack output sasToken)' -H 'Content-Type: application/atom+xml;type=entry;charset=utf-8' -d '{"Make":"Kia","Sales":2,"Time":"2019-06-26T10:22:36Z"}'
  7. Start the Stream Analytics job. The job will start emitting messages to the output Event Hub once per minute. The Azure Function analytics-output will start printing those events into the console (you’d have to open the function console in the Azure portal to see them).