flowchart LR
YSC[Yeedu Spark Compute]
UC[Unity Catalog]
ADLS2[ADLS Gen2 Storage - humuceastus2dev0 ]
YSC -->|1. Connect using URL & PAT| UC
UC -->|2. Return Catalog/Tables & ADLS2 Locations| YSC
YSC -->|3. Access ADLS2 locations using Azure SPN| ADLS2
UC -.->|RBAC Governance| ADLS2
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
from typing import Any, Optional, Dict, List | |
import requests, base64 | |
from pyspark.sql import SparkSession | |
from IPython.display import display, clear_output | |
from py4j.java_gateway import java_import | |
from datetime import datetime | |
import inspect, os, io | |
from IPython.display import display, Markdown | |
from IPython.core.interactiveshell import InteractiveShell | |
import logging |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
-----BEGIN RSA PRIVATE KEY----- | |
MIIEowIBAAKCAQEA2LxMpqMONHTnyetIeZO4CK9mRzJZIWxWuPy97k3eMnnP5BpE | |
wHJqUsHGofsgfWkhJiRLHUE2Ff5Vy3W/GdVFdGrvTJw8EpbBLh2TmGD/QiqhK/Tl | |
1xkEs8UzeqKc6PsZ1hlkWwjg6SiNpySyotX38RHNWxgzdjFyySoXHgRe1jx09+B7 | |
Yi1UtS3xM9BK5n4dOvNDBEQ8+I7AxDrsaFLhAPqOyApZDHYuVRCEqPIoNdX4LDtB | |
aAUXaQws2K6oDu3rK5k9IbzGbfqSnlnKNEPKZEKQkortGvB9TzGqWndwEBDtKIVm | |
KxnVTJWuSQ6mj5AnWiufw0Pk640w0B5DKS+/TwIDAQABAoIBABuOzbw+bVb0Kmi9 | |
NujmhHbuPnX9C+I5EUnSMSA03HTUkj9xq55Arg45v1TnRnlLvcBIyxg8K3FednA5 | |
V4QkXwFve1/lWaoPax6++f5dDvfNzdJ2ACd6ceOdxm7ocEUbcGyNq/n7RgW/d0ty | |
WhhkVnNbjR3xFNIJdYvogyn46koZB9Dcq5/wDJu+JfPurnRSSJC65fvRWTRJYOY4 |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
"permissions": [ | |
{ | |
"actions": [ | |
"Microsoft.Compute/sshPublicKeys/write", | |
"Microsoft.Compute/virtualMachines/read", | |
"Microsoft.Compute/virtualMachines/start/action", | |
"Microsoft.Compute/virtualMachines/restart/action", | |
"Microsoft.Compute/virtualMachines/deallocate/action", | |
"Microsoft.Compute/virtualMachines/delete", | |
"Microsoft.Compute/virtualMachines/write", |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/bin/bash | |
# Directory to store logs | |
LOG_DIR="/yeedu/reactors/logs/dstat" | |
mkdir -p "$LOG_DIR" | |
# Infinite loop to run the command every 60 seconds | |
while true | |
do |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@flow(retries=0, retry_delay_seconds=5, log_prints=True) | |
def test_job_variables(): | |
job_url = os.environ.get("job_url") | |
operator = YeeduOperator(job_url=job_url, | |
connection_block_name='connection-create-from-code', | |
login_password_block_name='secret-create-from-code') | |
operator.execute() | |
.deploy( | |
name="testing_job_variables", |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
import unittest | |
from unittest.mock import patch, MagicMock | |
import sys | |
import os | |
# # Ensure the project root directory is in sys.path | |
# project_root = os.path.abspath(os.path.join(os.path.dirname(__file__), '..')) | |
# if project_root not in sys.path: | |
# sys.path.append(project_root) |