我有grafana 3.0.4/Influxdb 0.13.0/telegraf 0.13.1
我试图用%来表示整体CPU使用率.
当我使用空闲时间创建查询时,我得到了(我正在寻找100 - 空闲时间)(使用)
我切换到手动模式并完成了:
它很棒..
但有没有办法在普通编辑器中使用数学函数或其他东西而不是进入手动文本模式?
我正在尝试使用 AWS Glue 将大约 1.5 GB 的 GZIPPED CSV 转换为 Parquet。下面的脚本是自动生成的 Glue 作业,用于完成该任务。似乎需要很长时间(我已经等了几个小时等待 10 个 DPU,但从未看到它结束或产生任何输出数据)
我想知道是否有人有将 1.5 GB + GZIPPED CSV 转换为 Parquet 的经验 - 有没有更好的方法来完成此转换?
我有 TB 的数据需要转换。令人担忧的是转换 GB 似乎需要很长时间。
我的 Glue 作业日志有数千个条目,例如:
18/03/02 20:20:20 DEBUG Client:
client token: N/A
diagnostics: N/A
ApplicationMaster host: 172.31.58.225
ApplicationMaster RPC port: 0
queue: default
start time: 1520020335454
final status: UNDEFINED
tracking URL: http://ip-172-31-51-199.ec2.internal:20888/proxy/application_1520020149832_0001/
user: root
Run Code Online (Sandbox Code Playgroud)
AWS 自动生成的 Glue 作业代码:
import sys
from awsglue.transforms import *
from awsglue.utils import getResolvedOptions
from pyspark.context …Run Code Online (Sandbox Code Playgroud) 我有以下架构:
input CreateEventInput {
userID: String!
eventID: ID!
type: String!
data: String
dateTime: AWSDateTime!
}
type Mutation {
createEvent(input: CreateEventInput!): event
}
type Subscription {
onCreateEvent(): event
@aws_subscribe(mutations: ["createEvent"])
Run Code Online (Sandbox Code Playgroud)
该createEvent解析器设置userID,如:
"key" : {
"userID" : $util.dynamodb.toDynamoDBJson($context.identity.username),
"eventID" : $util.dynamodb.toDynamoDBJson($util.autoId())
}
Run Code Online (Sandbox Code Playgroud)
我想限制订阅,以便只记录userID = $context.identity.username返回给用户的位置。
有谁知道如何设置?我想我需要一个关于订阅的解析器,但我找不到一个明确的例子,你有一个主分区键 ( userID) 和主排序键 ( eventID)。
我真的很感激任何帮助或指导。如果需要,我可以更改架构或数据库。
更新:
我相信我可以将订阅响应映射模板设置为:
#if(${context.identity.username} != ${context.arguments.userID})
$utils.unauthorized()
#else
##User is authorized, but we return null to continue
null
#end
Run Code Online (Sandbox Code Playgroud)
但是,我不知道在请求映射模板中放什么。
amazon-dynamodb amazon-cognito aws-appsync aws-amplify appsync-apollo-client
如何解除特定安全组与所有EC2实例的关联,然后将其与新的EC2实例关联,使用BOTO3?
我正在尝试这样的事情:
ec2 = boto3.resource('ec2')
instances = ec2.instances.filter()
for instance in instances:
print(instance.id, instance.instance_type)
for sg in instance.security_groups:
if sg['GroupId'] == sg_id:
instance.modify_attribute ???
Run Code Online (Sandbox Code Playgroud)
谢谢你的帮助!
amazon-ec2 ×1
apache-spark ×1
aws-amplify ×1
aws-appsync ×1
aws-glue ×1
boto3 ×1
grafana ×1
influxdb ×1
parquet ×1