from notebookutils import mssparkutils
import pandas as pd
import io
import base64
from azure.communication.email import EmailClient
from azure.keyvault.secrets import SecretClient
# ====== Load secrets from Azure Key Vault ======
# Replace "kv-emailcomm" with your actual Key Vault connection name in Fabric
CONNECTION_STRING = mssparkutils.credentials.getSecret("emailcommunicationkey", "ACS-CONNECTION-STRING")
SENDER = mssparkutils.credentials.getSecret("emailcommunicationkey", "SENDER-EMAIL")
# Initialize EmailClient
client = EmailClient.from_connection_string(CONNECTION_STRING)
# ====== Load churn data from Spark ======
df = spark.read.load(
""
)
churn_alert = df.toPandas()
# ====== Filter for test email (optional) ======
# If you want to send all data, skip this filter
# If you want only rows for girl, uncomment below:
# churn_alert = churn_alert[churn_alert['email'] == ' ']
# Create CSV attachment
csv_buffer = io.StringIO()
churn_alert.to_csv(csv_buffer, index=False)
csv_base64 = base64.b64encode(csv_buffer.getvalue().encode()).decode()
# Email Content
plain_text_content = (
f"Hello friend,\n\n"
"Hope you’re doing well. This is a test\n\n"
"Best regards,\ntesting team"
)
# Prepare message
message = {
"senderAddress": SENDER,
"recipients": {"to": [{"address": " "}]},
"content": {
"subject": "Churn Alert: Your Customers at Risk",
"plainText": plain_text_content
},
"attachments": [
{
"name": "churn_report.csv",
"contentType": "text/csv",
"contentInBase64": csv_base64
}
]
}
# Send email
try:
poller = client.begin_send(message)
result = poller.result()
print(f"✅ Email sent to " " | Message ID: {result['id']}")
except Exception as e:
print(f"❌ Failed to send email: {e}")
this is the output
--------------------------------------------------------------------------- Py4JJavaError Traceback (most recent call last) Cell In[49], line 14 7 from azure.keyvault.secrets import SecretClient 11 # ====== Load secrets from Azure Key Vault ====== 12 13 # Replace "kv-emailcomm" with your actual Key Vault connection name in Fabric ---> 14 CONNECTION_STRING = mssparkutils.credentials.getSecret("emailcommunicationkey", "ACS-CONNECTION-STRING") 15 SENDER = mssparkutils.credentials.getSecret("emailcommunicationkey", "SENDER-EMAIL") 19 # Initialize EmailClient File ~/cluster-env/trident_env/lib/python3.11/site-packages/notebookutils/mssparkutils/credentials.py:27, in getSecret(akvName, secret, linkedService) 25 def getSecret(akvName, secret, linkedService=''😞 26 if linkedService == '': ---> 27 return creds.getSecret(akvName, secret) 28 else: 29 return creds.getSecret(akvName, secret, linkedService) File ~/cluster-env/trident_env/lib/python3.11/site-packages/py4j/java_gateway.py:1322, in JavaMember.__call__(self, *args) 1316 command = proto.CALL_COMMAND_NAME +\ 1317 self.command_header +\ 1318 args_command +\ 1319 proto.END_COMMAND_PART 1321 answer = self.gateway_client.send_command(command) -> 1322 return_value = get_return_value( 1323 answer, self.gateway_client, self.target_id, self.name) 1325 for temp_arg in temp_args: 1326 if hasattr(temp_arg, "_detach"😞
