# Power BI Dataflows API operations
import requests
import json

# Get Dataflow from Power BI workspace
headers = {
    "Authorization": f"Bearer {access_token}",
    "Content-Type": "application/json"
}

# List dataflows
response = requests.get(
    "https://api.powerbi.com/v1.0/myorg/groups/{workspace_id}/dataflows",
    headers=headers
)

dataflows = response.json()["value"]
for df in dataflows:
    print(f"Dataflow: {df['name']}, ID: {df['id']}")

# Trigger dataflow refresh
response = requests.post(
    f"https://api.powerbi.com/v1.0/myorg/groups/{workspace_id}/dataflows/{dataflow_id}/refreshes",
    headers=headers,
    json={
        "notifyOption": "MailOnFailure"
    }
)

# Get refresh history
response = requests.get(
    f"https://api.powerbi.com/v1.0/myorg/groups/{workspace_id}/dataflows/{dataflow_id}/refreshes",
    headers=headers
)

# Power BI Dataset operations
from powerbiclient import Report, models

# Connect to Power BI dataset
dataset = models.Dataset(
    dataset_id="dataset-id",
    auth_token=access_token,
    workspace_id=workspace_id
)

# Execute DAX query
result = dataset.execute_dax_query(
    query="""
    EVALUATE
    SUMMARIZE(
        Sales,
        Sales[ProductCategory],
        "Total Revenue", SUM(Sales[TotalAmount]),
        "Total Transactions", COUNTROWS(Sales)
    )
    """
)

# Power BI XMLA endpoint for direct connectivity
# Connection string: 
# Data Source=powerbi://api.powerbi.com/v1.0/myorg/{workspace-name};
# Initial Catalog={dataset-name}

# Dataverse operations
from dataverse import DataverseClient
from azure.identity import DefaultAzureCredential

credential = DefaultAzureCredential()
client = DataverseClient(
    instance_url="https://org-name.crm.dynamics.com",
    credential=credential
)

# Query Dataverse table
query = """
<fetch>
    <entity name="account">
        <attribute name="name"/>
        <attribute name="revenue"/>
        <attribute name="industry"/>
        <filter>
            <condition attribute="createdon" operator="last-x-days" value="30"/>
        </filter>
    </entity>
</fetch>
"""

results = client.query(query)
for record in results:
    print(f"Account: {record['name']}, Revenue: {record['revenue']}")

# Upsert record
client.upsert(
    entity_name="custom_salesdata",
    entity_id="record-guid",
    data={
        "name": "Sales Record 2024",
        "totalamount": 150000.00,
        "statuscode": 1
    }
)