airflow_dag_powerbi_dataset_refresh_operator_quickstart.py

1from datetime import datetime
2from airflow import DAG
3from airflow_powerbi_plugin.operators.powerbi import PowerBIDatasetRefreshOperator
4
5with DAG(
6    dag_id='example_powerbi_refresh',
7    schedule_interval=None,
8    start_date=datetime(2023, 1, 1),
9    catchup=False,
10) as dag:
11
12    # Trigger a refresh for a specific Power BI dataset
13    refresh_dataset = PowerBIDatasetRefreshOperator(
14        task_id='refresh_powerbi_dataset',
15        dataset_id='your_dataset_id_here',
16        group_id='your_workspace_id_here', # Optional: Workspace ID
17        conn_id='powerbi_default'          # The Airflow connection ID for Power BI
18    )
19
20    refresh_dataset