AAD更改通知 - 使用"$deltaToken=latest"进行增量查询以跟踪最近更改
创始人
2024-07-21 18:00:06
0

下面是一个使用AAD Graph API进行增量查询的代码示例:

using System;
using System.Net.Http;
using System.Net.Http.Headers;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        string tenantId = "";
        string clientId = "";
        string clientSecret = "";

        string deltaToken = ""; // 初始增量令牌

        using (HttpClient client = new HttpClient())
        {
            // 获取访问令牌
            client.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", await GetAccessToken(tenantId, clientId, clientSecret));

            // 构建增量查询URL
            string requestUrl = $"https://graph.windows.net/{tenantId}/directoryObjects?api-version=1.6&$filter=signInActivity/lastSignInDateTime ge 2022-01-01T00:00:00Z&$deltaToken={deltaToken}";

            // 发送增量查询请求
            HttpResponseMessage response = await client.GetAsync(requestUrl);
            response.EnsureSuccessStatusCode();

            // 获取响应内容
            var result = await response.Content.ReadAsStringAsync();
            Console.WriteLine(result);

            // 解析响应中的增量令牌
            deltaToken = response.Headers.GetValues("odata.deltaLink").FirstOrDefault();
            Console.WriteLine(deltaToken);
        }

        Console.ReadLine();
    }

    static async Task GetAccessToken(string tenantId, string clientId, string clientSecret)
    {
        string authority = $"https://login.microsoftonline.com/{tenantId}";
        string resource = "https://graph.windows.net";

        using (HttpClient client = new HttpClient())
        {
            var requestParameters = new Dictionary()
            {
                { "grant_type", "client_credentials" },
                { "client_id", clientId },
                { "client_secret", clientSecret },
                { "resource", resource }
            };

            var requestContent = new FormUrlEncodedContent(requestParameters);

            HttpResponseMessage response = await client.PostAsync($"{authority}/oauth2/token", requestContent);
            response.EnsureSuccessStatusCode();

            var result = await response.Content.ReadAsStringAsync();
            var accessToken = JObject.Parse(result)["access_token"].Value();

            return accessToken;
        }
    }
}

在上述示例中,需要替换为你自己的租户ID,客户端ID和客户端密钥。

此示例中的增量查询URL中包含了一个过滤器,只返回从2022年1月1日以来有登录活动的目录对象。你可以根据需要修改过滤器条件。

增量查询响应中的增量令牌通过odata.deltaLink标头返回。你可以使用该令牌来进行后续的增量查询。

相关内容

热门资讯

Android Recycle... 要在Android RecyclerView中实现滑动卡片效果,可以按照以下步骤进行操作:首先,在项...
安装apache-beam==... 出现此错误可能是因为用户的Python版本太低,而apache-beam==2.34.0需要更高的P...
Android - 无法确定任... 这个错误通常发生在Android项目中,表示编译Debug版本的Java代码时出现了依赖关系问题。下...
Android - NDK 预... 在Android NDK的构建过程中,LOCAL_SRC_FILES只能包含一个项目。如果需要在ND...
Akka生成Actor问题 在Akka框架中,可以使用ActorSystem对象生成Actor。但是,当我们在Actor类中尝试...
Agora-RTC-React... 出现这个错误原因是因为在 React 组件中使用,import AgoraRTC from “ago...
Alertmanager在pr... 首先,在Prometheus配置文件中,确保Alertmanager URL已正确配置。例如:ale...
Aksnginxdomainb... 在AKS集群中,可以使用Nginx代理服务器实现根据域名进行路由。以下是具体步骤:部署Nginx i...
AddSingleton在.N... 在C#中创建Singleton对象通常是通过私有构造函数和静态属性来实现,例如:public cla...
Alertmanager中的基... Alertmanager中可以使用repeat_interval选项指定在一个告警重复发送前必须等待...