AlertLogic Azure Event Hub Collector
This repository contains the Microsoft Azure web application Node.js source code and an Azure Resource Manager (ARM) template to set up a data collector in Azure, which collects and forwards Event Hub events to the Alert Logic backend.
To perform the set up required to grant Alert Logic permission access to collect Event hub events, you must have access to the following:
- A Microsoft Azure account with administrative privileges
- An Alert Logic user account with administrative privileges
In the Azure AD portal, you must register a new web application.
To register an Azure web application to collect logs:
- Log into the Azure portal as an Active Directory tenant administrator.
- On the left side panel click
Azure Active Directory
, and then selectApp Registrations
. - Click
+ New application registration
, and then provide the following configuration parameters:Name
- Provide a name for the new application (For examplealehubcollector
).- Select
Web app/ API
asApplication type
. Sign-on URL
- Type a URL for the application (for examplehttp://alehubcollector.com
). Note This information is not used anywhere within your subscription.
- Click
Create
. - From the
All applications
tab on theApp registration (Preview)
blade, selectAll apps
, and then click the application name you created. - Note the
Application ID
, for example,a261478c-84fb-42f9-84c2-de050a4babe3
- On the
Settings
panel for the application, selectKeys
. - Type a key
Description
, and then setDuration
toNever expires
. - Click
Save
. Note: Save the key value, which you need during ARM template deployment. - From the
Registered App
blade, click the link underManaged application in local directory
, and then clickProperties
. - Get the
Service Principal ID
associated with the application. (TheService Principal ID
is labeled asObject ID
on the properties page.) Caution: This ID is not the sameObject ID
found under theRegistered app
view or under theSettings
.
From the Bash command line in Azure Cloud Shell run the following commands, where <username>
is your Alert Logic user name and <password>
is your Alert Logic password:
export AL_USERNAME='<username>'
auth=$(curl -SX POST -u $AL_USERNAME https://api.global-services.global.alertlogic.com/aims/v1/authenticate); export AL_ACCOUNT_ID=$(echo $auth | jq -r '.authentication.account.id'); export AL_USER_ID=$(echo $auth | jq -r '.authentication.user.id'); export AL_TOKEN=$(echo $auth | jq -r '.authentication.token'); if [ -z $AL_TOKEN ]; then echo "Authentication failure"; else roles=$(curl -SX GET -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/roles | jq -r '.roles[].name'); if [ "$roles" != "Administrator" ]; then echo "The $AL_USERNAME doesn’t have Administrator role. Assigned role is '$roles'"; else curl -SX POST -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/access_keys | jq .; fi; fi; unset AL_USERNAME;
For accounts with multi-factor authentication (MFA) enabled:
export AL_USERNAME='<username>'
auth=$(curl -SX POST -d '{"mfa_code": "<mfa_code_here>" }' -u $AL_USERNAME https://api.global-services.global.alertlogic.com/aims/v1/authenticate); export AL_ACCOUNT_ID=$(echo $auth | jq -r '.authentication.account.id'); export AL_USER_ID=$(echo $auth | jq -r '.authentication.user.id'); export AL_TOKEN=$(echo $auth | jq -r '.authentication.token'); if [ -z $AL_TOKEN ]; then echo "Authentication failure"; else roles=$(curl -SX GET -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/roles | jq -r '.roles[].name'); if [ "$roles" != "Administrator" ]; then echo "The $AL_USERNAME doesn’t have Administrator role. Assigned role is '$roles'"; else curl -SX POST -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/access_keys | jq .; fi; fi; unset AL_USERNAME;
An example of a successful response is:
{
"access_key_id": "712c0b413eef41f6",
"secret_key": "1234567890b3eea8880d292fb31aa96902242a076d3d0e320cc036eb51bf25ad"
}
Note: If the output is blank, verify the Alert Logic user account permissions. You must have administrator access. For more information about AIMS APIs, see Access and Identity Management Service.
Note the access_key_id
and the secret_key
values for use in the deployment steps below.
Note: An account can create only five access keys. If you receive a "limit exceeded" response, you must delete some keys to create more. Use the following command to list access keys:
curl -s -X GET -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/access_keys | jq
Then use the selected access_key_id in the following curl command to delete the key:
curl -X DELETE -H "x-aims-auth-token: $AL_TOKEN" https://api.global-services.global.alertlogic.com/aims/v1/$AL_ACCOUNT_ID/users/$AL_USER_ID/access_keys/<ACCESS_KEY_ID_HERE>
You can use either the Microsoft Azure portal or a command line to deploy the template. To perform either procedure, you must log into the Azure portal.
Note: The steps in this section require an active Azure subscription. To verify your Azure subscription, visit Azure subscriptions blade.
If your organization uses multiple Active Directory tenants, log into the same tenant used to Register a New Azure Web Application.
Click the button below to start deployment.
- Provide the following required template parameters and click the
Purchase
button to start a deployment:Name
- Type the name of the log source to appear in the Alert Logic console.Storage Name
- Any storage account name (that does not currently exist).Alert Logic Access Key ID
- Theaccess_key_id
you created aboveAlert Logic Secret Key
- Thesecret_key
you created above.Alert Logic API endpoint
- Leave the default value (api.global-services.global.alertlogic.com).Alert Logic Data Residency
- Leave the value asdefault
.Service Principal ID
- TheObject ID
of the application that created the subscription. Noe You can obtain this value from Azure -> AD -> App registrations -> Your app name -> Link under Managed application in local directory -> Properties -> Object ID.App Client ID
- The GUID of your application that created the subscription. Note You can obtain this value from Azure -> AD -> App registrations -> Your app nameApp Client Secret
- The secret key of your application from App Registrations
- Click
Purchase
.
If you want to deploy the template through the Azure command line (CLI), you can use either Azure Cloud Shell or a local installation of Azure CLI.
To deploy through the Azure CLI:
- In the command line, type the following to create a new resource group.
Note The example below creates a new resource group in the "Central US" location.)
az group create --name <new-resource-group-name> --location "Central US"
- In the Azure portal, access the
Resource groups
blade, and then select the resource group you created. - Select
Access Control (IAM)
, and addWebsite Contributor
role to the Active Directory application identity you created above. - In the command line, type the following command to deploy a template, and enter the required parameters when prompted.
az group deployment create \ --resource-group <new-resource-group-name> \ --template-uri "https://raw.githubusercontent.com/alertlogic/ehub-collector/master/templates/ehub.json"
To verify successful installation of the template:
- In the Azure portal, access
Function Apps
, and then choose the Alert Logic Event Hub collector function. - Click
Functions
->Master
->Monitor
and verify the recent log entry has the status ofOK
and contains no error messages. Example:Ehub source checkin OK
. - In the Alert Logic console, navigate to
Configuration
->Deployments
->All Deployments
->Log Sources
, and then filter the list byPush (Office 365, EventHub)
collection method. - Verify a new Azure Event Hub log source with the name provided during
az group deployment create
above appears with the source status asOK
.
This section contains helpful links to instructions of how to integrate different Azure services with event hubs. Please select alertlogic-log
as a target event hub name if this option is available during configuration.
- Azure Active Directory Logs
- Azure Diagnostic Logs
- Azure Activity Logs
- Azure Security Center Events
- Azure SQL Audit Logs
The template creates an AlertLogicIngest-<region-name>-<unique-string>
Event Hub Namespace where alertlogic-log
event hub is created. Collector Azure function listens to event hub and forwards incoming events to the Alert Logic Ingestion service. If data processing fails the data is stored in alertlogic-dl
Azure Blob container located in the storage account specified during template deployment.
The Master
function is a timer trigger function responsible for:
- Registering the Azure web application in the Alert Logic backend
- Reporting health-checks to the backend
Note: When you release a new version of the collector, remember to increment the version number in npm package.json file.
The Updater
function is a timer triggered function that runs a deployment sync operation every 12 hours to keep web application up to date.
The EHubActivityLogs
function listens to insights-operational-logs
Event Hub located in the Event Hub namespace created during collector setup. The insights-operational-logs
is created automatically by Azure when a subscription's Log Profile is integrated with Event Hub via Azure Monitor service.
Follow this guide to Stream the Azure Activity Log to Event Hubs.
Collected JSON objects are wrapped into the protobuf structure and then are forwarded to the Alert Logic Ingestion service.
The EHubGeneral
function listens to alertlogic-log
which is created during collector setup. The alertlogicloghub
event hub can be used for integration with, for example, diagnostic logs or Azure AD logs.
Collected JSON objects are wrapped into the protobuf structure and then are forwarded to the Alert Logic Ingestion service.
Both EHubActivityLogs
and EHubGeneral
may not be able to process incoming event hub records. If that happens then unprocessed messages are saved as blobs to the alertlogic-dl
container so that collection can be retried at a later time. The alertlogic-dl
container is located in the collector web application storage account which is created durign collector setup.
The DLBlob
function processes dead letter blobs very 15 minutes. The DLBlob
function lists all blobs located in alertlogic-dl
container and processes them according to the function which dead letter blob belongs to. Once a blob is processed it gets removed from the container.
- Clone the repo
git clone git@github.com:alertlogic/ehub-collector.git
. cd ehub-collector
- Run
./local_dev/setup.sh
. - Edit
./local_dev/dev_config.js
. - Run the Master function locally:
npm run local-master
. - Run the Updater function locally:
npm run local-updater
. - Run the EHubGeneral function locally:
npm run local-ehub-general
. - Run the EHubActivityLogs function locally:
npm run local-ehub-activitylogs
. - Run
npm test
to perform code analysis and unit tests.
Please use the following code style as much as possible.
process.env.APP_TENANT_ID
- The GUID of the tenant (such asalazurealertlogic.onmicrosoft.com
)process.evn.APP_RESOURCE_GROUP
- The name of the resource group where you deployed your application.process.env.CUSTOMCONNSTR_APP_CLIENT_ID
- The GUID of your application that created the subscription. Note You can obtain this value from Azure -> AD -> App registrations -> Your app nameprocess.env.CUSTOMCONNSTR_APP_CLIENT_SECRET
- The secret key of your application from App Registrations.process.env.CUSTOMCONNSTR_APP_CI_ACCESS_KEY_ID
- The access key returned from AIMs above.process.env.CUSTOMCONNSTR_APP_CI_SECRET_KEY
- The secret key returned from AIMs above.
- Sometimes deployments fail after siteSync action. We need better updater to handle that in order not to wait for 12 hours for the next update attempt.