msticpy.data.drivers.resource_graph_driver module

Azure Resource Graph Driver class.

class msticpy.data.drivers.resource_graph_driver.ResourceGraphDriver(**kwargs)

Bases: DriverBase

Driver to connect and query from Azure Resource Graph.

Instantiate Azure Resource Graph Driver.

add_query_filter(name, query_filter)

Add an expression to the query attach filter.

connect(connection_str: Optional[str] = None, **kwargs)

Connect to Azure Resource Graph via Azure SDK.

Parameters
  • connection_str (Optional[str], optional) – Not used.

  • kwargs – Connection parameters can be supplied as keyword parameters.

Notes

Default configuration is read from the DataProviders/AzureCLI section of msticpyconfig.yaml, if available.

property connected: bool

Return true if at least one connection has been made.

Returns

True if a successful connection has been made.

Return type

bool

Notes

This does not guarantee that the last data source connection was successful. It is a best effort to track whether the provider has made at least one successful authentication.

property driver_queries: Iterable[Dict[str, Any]]

Return queries retrieved from the service after connecting.

Returns

List of Dictionary of query_name, query_text. Name of container to add queries to.

Return type

List[Dict[str, str]]

static get_http_timeout(**kwargs)

Get http timeout from settings or kwargs.

property instance: Optional[str]

Return instance name, if one is set.

Returns

The name of driver instance or None if the driver does not support multiple instances

Return type

Optional[str]

property loaded: bool

Return true if the provider is loaded.

Returns

True if the provider is loaded.

Return type

bool

Notes

This is not relevant for some providers.

query(query: str, query_source: Optional[QuerySource] = None, **kwargs) Union[DataFrame, Any]

Execute Resource Graph query and retrieve results.

Parameters
  • query (str) – KQL query to execute

  • query_source (QuerySource) – The query definition object

  • kwargs – count

Returns

Query results in a dataframe. or query response if an error.

Return type

Union[pd.DataFrame, Any]

property query_attach_spec: Dict[str, Set[str]]

Parameters that determine whether a query is relevant for the driver.

query_with_results(query: str, **kwargs) Tuple[DataFrame, Any]

Execute query string and return DataFrame of results.

Parameters

query (str) – Query to execute against Resource Graph

Returns

A DataFrame (if successful) or the underlying provider result if an error occurs.

Return type

Union[pd.DataFrame,Any]

property schema: Dict[str, Dict]

Return current data schema of connection.

Returns

Data schema of current connection.

Return type

Dict[str, Dict]

property service_queries: Tuple[Dict[str, str], str]

Return queries retrieved from the service after connecting.

Returns

Dictionary of query_name, query_text. Name of container to add queries to.

Return type

Tuple[Dict[str, str], str]