msgraph-sdk

import asyncio import os from azure.identity.aio import ClientSecretCredential from kiota_authentication_azure.azure_identity_authentication_provider import AzureIdentityAuthenticationProvider from msgraph import GraphServiceClient from msgraph.generated.models.message import Message async def main(): # Environment variables for client credentials flow tenant_id = os.environ.get('TENANT_ID', 'YOUR_TENANT_ID') client_id = os.environ.get('CLIENT_ID', 'YOUR_CLIENT_ID') client_secret = os.environ.get('CLIENT_SECRET', 'YOUR_CLIENT_SECRET') user_id = os.environ.get('USER_ID', 'YOUR_USER_ID') # User to fetch messages from # Ensure required environment variables are set if not all([tenant_id, client_id, client_secret, user_id]): print("Please set TENANT_ID, CLIENT_ID, CLIENT_SECRET, and USER_ID environment variables.") return # For app-only permissions, use the .default scope scopes = ['https://graph.microsoft.com/.default'] # Create a credential object credential = ClientSecretCredential( tenant_id=tenant_id, client_id=client_id, client_secret=client_secret ) # Create an authentication provider auth_provider = AzureIdentityAuthenticationProvider(credential, scopes=scopes) # Create a GraphServiceClient client = GraphServiceClient(auth_provider) try: # Fetch messages for a specific user # Note: This requires Mail.Read.All application permission or Mail.Read delegated permission for the user_id # if using delegated flow. messages_collection = await client.users.by_user_id(user_id).messages.get() if messages_collection and messages_collection.value: print(f"Successfully fetched {len(messages_collection.value)} messages for user {user_id}:") for msg in messages_collection.value: print(f" Subject: {msg.subject}, From: {msg.sender.email_address.address}") else: print(f"No messages found for user {user_id}.") except Exception as e: print(f"Error fetching messages: {e}") if __name__ == '__main__': asyncio.run(main())