Stability Level Long-Term
API Stability Long-Term

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

Syntax

Below is the syntax for the testAzureEventHubIngestFeed() mutation field:

graphql
testAzureEventHubIngestFeed(
      input: TestAzureEventHubIngestFeed!
    ): boolean

Below is an example of how this mutation field might be used:

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/graphql',
  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"
    }
  }
}

Given Datatypes

For the TestAzureEventHubIngestFeed given datatype, there are a few parameters. Below is a list of them, along with a description of each.

Table: TestAzureEventHubIngestFeed

ParameterTypeRequiredDefaultStabilityDescription
Some arguments may be required, as indicated in the Required column. For some fields, this column indicates that a result will always be returned for this column.
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.