我正在尝试使用 .NET 从 CloudWatch 读取使用 SNS 发送的消息的日志数据。
从 CloudWatch 控制台 (CloudWatch \ CloudWatch Logs \ Logs Insights),我输入:
Date range: custom (2w)
LogGroup: sns/ap...../8...../LogName
Query: fields @timestamp, @message | sort @timestamp desc | limit 20
它返回大量日志记录(@timestamp | @message)
我正在尝试使用 .net AWS SDK 从 c# 执行相同的操作:
public async Task GetLogs()
{
string logGroupName = "sns/ap...../8...../LogName";
AWSOptions options = configuration.GetAWSOptions();
IAmazonCloudWatchLogs logs = options.CreateServiceClient<IAmazonCloudWatchLogs>();
StartQueryRequest startQueryRequest = new StartQueryRequest();
startQueryRequest.LogGroupName = logGroupName;
startQueryRequest.StartTime = 1577850562; //1 Jan 2020
TimeSpan t = DateTime.UtcNow - new DateTime(1970, 1, 1); //Epoch time starts on 1/1/1970
int secondsSinceEpoch = (int)t.TotalSeconds;
startQueryRequest.EndTime = secondsSinceEpoch;
startQueryRequest.QueryString = "fields @timestamp, @message | sort @timestamp desc";
startQueryRequest.Limit = 1000;
StartQueryResponse response2 = await logs.StartQueryAsync(startQueryRequest);
Console.WriteLine();
}
无法弄清楚为什么它不返回任何记录。
Response2 =
ContentLength: 50
QueryId: "guid..."
ResponseMetadata:
Metadata Count = 0
RequestId = "guid..."
知道我做错了什么吗?谢谢!
如果它对其他人有帮助 - 这是我使用 C# 从 AWS 获取日志的方法
public async Task GetLogs()
{
string logGroupName = "log group name from CloudWatch Log";
AWSOptions options = configuration.GetAWSOptions();
IAmazonCloudWatchLogs logs = options.CreateServiceClient<IAmazonCloudWatchLogs>();
StartQueryRequest startQueryRequest = new StartQueryRequest();
startQueryRequest.LogGroupName = logGroupName;
startQueryRequest.StartTime = 1577850562; //1 Jan 2020
TimeSpan t = DateTime.UtcNow - new DateTime(1970, 1, 1); //Epoch time starts on 1/1/1970
int secondsSinceEpoch = (int)t.TotalSeconds;
startQueryRequest.EndTime = secondsSinceEpoch;
startQueryRequest.QueryString = "fields @timestamp, @message | sort @timestamp desc";
startQueryRequest.Limit = 1000;
StartQueryResponse startQueryResponse = await logs.StartQueryAsync(startQueryRequest);
GetQueryResultsRequest getQueryRequest = new GetQueryResultsRequest();
getQueryRequest.QueryId = startQueryResponse.QueryId;
GetQueryResultsResponse getQueryResults = await logs.GetQueryResultsAsync(getQueryRequest);
for (var i=0; i<getQueryResults.Results.Count; i++)
{
ResultField timestampResult = getQueryResults.Results[i][0];
ResultField messageResult = getQueryResults.Results[i][1];
var message = JsonConvert.DeserializeObject(messageResult.Value);
Console.WriteLine(message);
}
Console.WriteLine();
}
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)