create Folder latest / move Update out of Version to rename
This commit is contained in:
@@ -0,0 +1,117 @@
|
||||
import msal
|
||||
import requests
|
||||
import pandas as pd
|
||||
from datetime import datetime
|
||||
|
||||
# Konfigurationsvariablen
|
||||
client_id = '90571c9b-d407-4d2a-aadd-4a523ff85296'
|
||||
client_secret = 'ryp8Q~qr6LBOUL2G333a.mf-vg5V..ONl7qJTdza'
|
||||
tenant_id = '9e449aaa-285c-4572-a132-58db027026d0'
|
||||
api_server_endpoint = "http://api.stines.de:8001/office/post"
|
||||
# headers = 'access_token':'^YWUbG7yX*V!tV^KBSd*2c&vdN3wV9a2i7f3hfGFMBYFxi6#mMiJGiaA5KEHE%B*miK%qb7rQ67gmcYP@gqmux8'
|
||||
|
||||
# Die URL für das Token
|
||||
authority = f'https://login.microsoftonline.com/{tenant_id}'
|
||||
|
||||
# Der Scope für die Microsoft Graph API
|
||||
scope = ['https://graph.microsoft.com/.default']
|
||||
|
||||
# MSAL-Instanz erstellen
|
||||
app = msal.ConfidentialClientApplication(
|
||||
client_id,
|
||||
authority=authority,
|
||||
client_credential=client_secret,
|
||||
)
|
||||
|
||||
# Token erhalten
|
||||
result = None
|
||||
result = app.acquire_token_silent(scope, account=None)
|
||||
|
||||
if not result:
|
||||
print("Kein Caching vorhanden, holen Sie ein neues Token.")
|
||||
result = app.acquire_token_for_client(scopes=scope)
|
||||
print(result)
|
||||
|
||||
if "access_token" in result:
|
||||
# Token erfolgreich erhalten
|
||||
access_token = result['access_token']
|
||||
|
||||
print(access_token)
|
||||
|
||||
# API-Endpunkt für aktive Office-Pakete
|
||||
endpoint = "https://graph.microsoft.com/v1.0/users?$select=userPrincipalName,assignedLicenses,signInActivity"
|
||||
|
||||
|
||||
headers = {
|
||||
'Authorization': f'Bearer {access_token}',
|
||||
'Content-Type': 'application/json'
|
||||
}
|
||||
|
||||
response = requests.get(endpoint, headers=headers)
|
||||
|
||||
if response.status_code == 200:
|
||||
# Die Antwort als JSON behandeln
|
||||
data = response.json()
|
||||
|
||||
# Extrahieren der Benutzerdaten aus dem JSON
|
||||
users = data.get('value', [])
|
||||
|
||||
# Die `skuId` und `lastNonInteractiveSignInDateTime` extrahieren und hinzufügen
|
||||
user_list = []
|
||||
for user in users:
|
||||
if 'assignedLicenses' in user:
|
||||
for license in user['assignedLicenses']:
|
||||
if 'skuId' in license:
|
||||
user_copy = user.copy()
|
||||
user_copy['skuId'] = license['skuId']
|
||||
if user_copy.get('signInActivity'):
|
||||
sign_in_time = user_copy['signInActivity'].get('lastNonInteractiveSignInDateTime')
|
||||
if sign_in_time:
|
||||
user_copy['lastNonInteractiveSignInDateTime'] = datetime.strptime(sign_in_time,'%Y-%m-%dT%H:%M:%SZ').strftime('%Y-%m-%d %H:%M:%S')
|
||||
else:
|
||||
user_copy['lastNonInteractiveSignInDateTime'] = None
|
||||
else:
|
||||
user_copy['lastNonInteractiveSignInDateTime'] = None
|
||||
user_list.append(user_copy)
|
||||
|
||||
# Filtern der Benutzer, die eine `skuId` haben
|
||||
users_with_skuId = [user for user in user_list if user['skuId']]
|
||||
|
||||
# Konvertieren der Benutzerdaten in ein DataFrame
|
||||
df = pd.DataFrame(users_with_skuId)
|
||||
|
||||
# Pandas Anzeigeoptionen anpassen
|
||||
pd.set_option('display.max_columns', None)
|
||||
pd.set_option('display.max_rows', None)
|
||||
pd.set_option('display.max_colwidth', None)
|
||||
pd.set_option('display.width', 1000)
|
||||
|
||||
# Alles nach dem @ im "User Principal Name" entfernen
|
||||
if 'userPrincipalName' in df.columns:
|
||||
df['userPrincipalName'] = df['userPrincipalName'].str.split('@').str[0]
|
||||
|
||||
# Nur die gewünschten Spalten auswählen und an die API-Server übergeben
|
||||
selected_columns = df[["userPrincipalName", "skuId", "lastNonInteractiveSignInDateTime"]]
|
||||
reporting_date = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
|
||||
|
||||
for index, row in selected_columns.iterrows():
|
||||
payload = {
|
||||
"itemkey": row["skuId"],
|
||||
"username": row["userPrincipalName"],
|
||||
"reportingdate": reporting_date,
|
||||
"lastaccess": row["lastNonInteractiveSignInDateTime"]
|
||||
}
|
||||
api_response = requests.post(api_server_endpoint, json=payload, headers= {'access_token':'^YWUbG7yX*V!tV^KBSd*2c&vdN3wV9a2i7f3hfGFMBYFxi6#mMiJGiaA5KEHE%B*miK%qb7rQ67gmcYP@gqmux8'})
|
||||
if api_response.status_code == 200:
|
||||
print(f"Erfolgreich gesendet: {payload}")
|
||||
else:
|
||||
print(f"Fehler beim Senden von {payload}: {api_response.status_code} - {api_response.text}")
|
||||
|
||||
else:
|
||||
print(f"Fehler beim Abrufen der Daten: {response.status_code}")
|
||||
print(f"Antwort: {response.text}")
|
||||
else:
|
||||
print("Fehler beim Abrufen des Tokens")
|
||||
print(result.get("error"))
|
||||
print(result.get("error_description"))
|
||||
print(result.get("correlation_id"))
|
||||
Reference in New Issue
Block a user