Summary

The testAzureEventHubIngestFeed() GraphQL mutation is used to test whether the Azure Event Hubs and blob storage container is setup with the correct permissions.

Stability Level Long-Term

Syntax

graphql
testAzureEventHubIngestFeed(
      input: TestAzureEventHubIngestFeed!
    ): boolean

For the input, you'll have to give the name of the repository of the ingest feed, the name of the Event Hub, the authentication method to use, and other parameters. See the Input Parameters section for more.

For the results, you'll receive confirmation if successful.

Example

Raw
graphql
mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: "developer",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: "https://storagedtaa7rvhirbwq.blob.core.windows.net",
        containerName: "checkpointing"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: "$Default",
    eventHubName: "test-hub",
    eventHubFullyQualifiedNamespace: "evh-ingest-temp-2.servicebus.windows.net"
  })
}
Mac OS or Linux (curl)
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql \
    -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json" \
    -d @- << EOF
{"query" : "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}"
}
EOF
Mac OS or Linux (curl) One-line
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql \
    -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json" \
    -d @- << EOF
{"query" : "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}"
}
EOF
Windows Cmd and curl
shell
curl -v -X POST $YOUR_LOGSCALE_URL/graphql ^
    -H "Authorization: Bearer $TOKEN" ^
    -H "Content-Type: application/json" ^
    -d @'{"query" : "mutation testAzureIngestFeed { ^
  testAzureEventHubIngestFeed(input: { ^
    repositoryName: \"developer\", ^
    checkpointHandling: { ^
      kind: BlobStorage ^
      blobStorage: { ^
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\", ^
        containerName: \"checkpointing\" ^
      }, ^
    }, ^
    authentication: { ^
      kind: LogScaleConfig ^
    }, ^
 ^
    consumerGroup: \"$Default\", ^
    eventHubName: \"test-hub\", ^
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\" ^
  }) ^
}" ^
} '
Windows Powershell and curl
powershell
curl.exe -X POST 
    -H "Authorization: Bearer $TOKEN"
    -H "Content-Type: application/json"
    -d '{"query" : "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}"
}'
    "$YOUR_LOGSCALE_URL/graphql"
Perl
perl
#!/usr/bin/perl

use HTTP::Request;
use LWP;

my $TOKEN = "TOKEN";

my $uri = '$YOUR_LOGSCALE_URL/graphql';

my $query = "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}";
$query =~ s/\n/ /g;
my $json = sprintf('{"query" : "%s"}',$query);
my $req = HTTP::Request->new("POST", $uri );

$req->header("Authorization" => "Bearer $TOKEN");
$req->header("Content-Type" => "application/json");

$req->content( $json );

my $lwp = LWP::UserAgent->new;

my $result = $lwp->request( $req );

print $result->{"_content"},"\n";
Python
python
#! /usr/local/bin/python3

import requests

url = '$YOUR_LOGSCALE_URL/graphql'
mydata = r'''{"query" : "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}"
}'''

resp = requests.post(url,
                     data = mydata,
                     headers = {
   "Authorization" : "Bearer $TOKEN",
   "Content-Type" : "application/json"
}
)

print(resp.text)
Node.js
javascript
const https = require('https');

const data = JSON.stringify(
    {"query" : "mutation testAzureIngestFeed {
  testAzureEventHubIngestFeed(input: {
    repositoryName: \"developer\",
    checkpointHandling: {
      kind: BlobStorage
      blobStorage: {
        blobStorageEndpoint: \"https://storagedtaa7rvhirbwq.blob.core.windows.net\",
        containerName: \"checkpointing\"
      },
    },
    authentication: {
      kind: LogScaleConfig
    },

    consumerGroup: \"$Default\",
    eventHubName: \"test-hub\",
    eventHubFullyQualifiedNamespace: \"evh-ingest-temp-2.servicebus.windows.net\"
  })
}"
}
);


const options = {
  hostname: '$YOUR_LOGSCALE_URL',
  path: 'graphql',
  port: 443,
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Content-Length': data.length,
    Authorization: 'BEARER ' + process.env.TOKEN,
    'User-Agent': 'Node',
  },
};

const req = https.request(options, (res) => {
  let data = '';
  console.log(`statusCode: ${res.statusCode}`);

  res.on('data', (d) => {
    data += d;
  });
  res.on('end', () => {
    console.log(JSON.parse(data).data);
  });
});

req.on('error', (error) => {
  console.error(error);
});

req.write(data);
req.end();
Example Responses
Success (HTTP Response Code 200 OK)
json
{
  "data": {
    "testAzureIngestFeed": {
      "true"
    }
  }
}

Input Parameters

For the input, you would provide name of the repository of the ingest feed, the name of the Event Hub, the authentication method to use, and other parameters. These are listed and explained in the table below:

Table: TestAzureEventHubIngestFeed Input Datatype

ParameterTypeRequiredDefaultStabilityDescription
Some input parameters may be required, as indicated in the Required column. For return values, this indicates that you are assured a value if the field is requested for the results.
Table last updated: May 20, 2025
authenticationAzureEventHubsAuthenticationInputyes PreviewAuthentication method for Azure Event Hub. See AzureEventHubsAuthenticationInput.
checkpointHandlingAzureEventHubsCheckpointHandlingInputyes PreviewConfiguration for how the Event Hub checkpoints should be handled. See AzureEventHubsCheckpointHandlingInput.
consumerGroupstringyes PreviewConsumer group for the Event Hub.
eventHubFullyQualifiedNamespacestringyes PreviewFully qualified namespace of the Event Hub. Often structured like <namespace>.servicebus.windows.net.
eventHubNamestringyes PreviewThe name of the Event Hub.
repositoryNameRepoOrViewNameyes PreviewThe name of the repository for the ingest feed. RepoOrViewName is a scalar.