74 lines
2.6 KiB
PowerShell
74 lines
2.6 KiB
PowerShell
# Définir les variables de configuration
|
|
#$jsonKeyFile = "d6cd222549da.json" # Modifier le chemin vers votre fichier JSON d'authentification
|
|
$jsonKeyFile = "24a11fe72e5.json"
|
|
#$projectId = "abc-prj-np-mdf-001"
|
|
$projectId = "abc-prj-mdf-001"
|
|
$Topic = "MindFlow:publish"
|
|
$subscription = "Alerte:pull"
|
|
$APIUrl = "https://pubsub.googleapis.com/v1"
|
|
$subject = "Azure Activity"
|
|
$Message = "Message Lundi 26 Mai Test en directe à 15:40"
|
|
|
|
$data = $null
|
|
$responsePublish = $null
|
|
$responsePull = $null
|
|
|
|
# Activer le compte de service avec le fichier JSON
|
|
Write-Output "Activation du compte de service..."
|
|
gcloud auth activate-service-account --key-file $jsonKeyFile
|
|
|
|
# Récupérer le token d'accès
|
|
Write-Output "Récupération du token d'accès..."
|
|
$accessToken = gcloud auth print-access-token
|
|
|
|
# Définir l'URL de l'API Pub/Sub pour une opération de pull (récupération de messages)
|
|
$PublishUrl = "$APIUrl/projects/$projectId/topics/$topic"
|
|
$PullUrl = "$APIUrl/projects/$projectId/subscriptions/$subscription"
|
|
|
|
# Publier le message sur le topic Pub/Sub
|
|
#$base64Message = [Convert]::ToBase64String([System.Text.Encoding]::UTF8.GetBytes($Message))
|
|
|
|
$Headers = @{
|
|
Authorization = "Bearer $accessToken"
|
|
"accept" = "application/json"
|
|
"Content-Type" = "application/json"
|
|
}
|
|
|
|
# Préparer le corps de la requête (ici, on demande jusqu'à 10 messages)
|
|
$payloadPublish = @{
|
|
messages = @(
|
|
@{
|
|
data = [Convert]::ToBase64String([System.Text.Encoding]::UTF8.GetBytes($Message))
|
|
attributes = @{
|
|
subject = $subject
|
|
}
|
|
}
|
|
)
|
|
} | ConvertTo-Json -Depth 10
|
|
|
|
Write-Output "Utilisation de l'API Pub/Sub..."
|
|
# Appeler l'API Pub/Sub avec une requête POST
|
|
$responsePublish = Invoke-RestMethod -Method POST -Uri $PublishUrl -Headers $Headers -Body $payloadPublish
|
|
|
|
# Afficher la réponse
|
|
Write-Output "Réponse de l'API :" $responsePublish | ConvertTo-Json -Depth 10
|
|
|
|
# Préparer le corps de la requête (ici, on demande jusqu'à 10 messages)
|
|
$payloadPull = @{
|
|
maxMessages = 10
|
|
} | ConvertTo-Json -Depth 10
|
|
|
|
Write-Output "Interrogation de l'API Pub/Sub..."
|
|
# Appeler l'API Pub/Sub avec une requête POST
|
|
$responsePull = Invoke-RestMethod -Method Post -Uri $pullUrl -Headers $headers -Body $payloadPull # -ContentType "application/json"
|
|
|
|
# Afficher la réponse
|
|
If ($responsePull.receivedMessages) {
|
|
Write-Host "Message tiré. Réponse : " $responsePull.receivedMessages
|
|
Foreach ($message in $responsePull.receivedMessages) {
|
|
$data = [System.Text.Encoding]::UTF8.GetString([Convert]::FromBase64String($message.message.data))
|
|
Write-Host "Received message: $data"
|
|
|
|
}
|
|
}
|