src/sample/XXX.Plugin.Tdengine/Proxy/ITaosProxy.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using System.Net;
using WebApiClientCore;
using WebApiClientCore.Attributes;
using HttpPostAttribute = WebApiClientCore.Attributes.HttpPostAttribute;

namespace XXX.Plugin.Tdengine
{
    /// <summary>
    /// 主机地址配置在 appsetting.json >NetProProxyOption
    /// 获取或设置Http服务完整主机域名 例如http://www.abc.com设置了HttpHost值，HttpHostAttribute将失效
    /// [HttpHost("https://www.taosdata.com/docs/cn/v2.0/connector#restful")]
    /// </summary>
    public interface ITaosProxy
    {
        /// <summary>
        /// 执行sql
        /// https://www.taosdata.com/docs/cn/v2.0/connector#restful
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="database"></param>
        /// <returns></returns>
        [HttpPost("/rest/sqlt/{database}")]
        [ApiClientFilter]
        ITask<dynamic> ExecuteSql([RawStringContent("text/plain")] string sql, string database = "test");
    }

    public class ApiClientFilter : ApiFilterAttribute
    {
        /// <summary>
        /// 
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>

        public override Task OnRequestAsync(ApiRequestContext context)
        {
            var configuration = context.HttpContext.ServiceProvider.GetService<IConfiguration>();
            configuration.GetValue<string>("Taos:Name");
            configuration.GetValue<string>("Taos:Pwd");
            string name = "root";
            string pwd = "taosdata";

            string token = $"{name}:{pwd}".Base64();

            context.HttpContext.RequestMessage.Headers.Add("Authorization", $"Basic {token}");
            var uri = context.HttpContext.RequestMessage.RequestUri;
            Console.WriteLine($"request uri is：{uri}");
            return Task.CompletedTask;
        }

        public override async Task OnResponseAsync(ApiResponseContext context)
        {
            var _logger = context.HttpContext.ServiceProvider.GetService<ILogger<ApiClientFilter>>();

            try
            {
                if (_logger != null)
                {