Stability Level 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.

You can use the createAzureEventHubIngestFeed() mutation to create a new ingest feed which uses Azure. Use the updateAzureEventHubIngestFeed() mutation to update one. To delete any ingest feed, use the deleteIngestFeed() mutation.

Hide Query Example

Show Azure Ingest Feeds Query

Syntax

graphql
testAzureEventHubIngestFeed(
      input: TestAzureEventHubIngestFeed!
    ): boolean

There are no special returned datatypes for this mutation field.

Example

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',
  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 Datatype

For this input datatype, 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

ParameterTypeRequiredDefaultStabilityDescription
Some arguments may be required, as indicated in the Required column. For return datatypes, this indicates that you must specify which fields you want returned in 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.