开始使用

安全组规则修改（可选）

Kafka默认使用9092端口，该方案默认针对子网网段开放，请参考修改安全组规则，配置IP地址白名单，以便能正常访问服务。

安全组实际是网络流量访问策略，包括网络流量入方向规则和出方向规则，通过这些规则为安全组内具有相同保护需求并且相互信任的云服务器、云容器、云数据库等实例提供安全保护。

如果您的实例关联的安全组策略无法满足使用需求，比如需要添加、修改、删除某个TCP端口，请参考以下内容进行修改。

添加安全组规则：根据业务使用需求需要开放某个TCP端口，请参考添加安全组规则添加入方向规则，打开指定的TCP端口。
修改安全组规则：安全组规则设置不当会造成严重的安全隐患。您可以参考修改安全组规则，来修改安全组中不合理的规则，保证云服务器等实例的网络安全。
删除安全组规则：当安全组规则入方向、出方向源地址/目的地址有变化时，或者不需要开放某个端口时，您可以参考删除安全组规则进行安全组规则删除。

查看Kafka。在控制台单击“服务列表”，选择“分布式消息服务Kafka版”，在“Kafka专享版”页面找到该方案所创建的Kafka实例。单击进入实例管理控制台。

图1 Kafka实例
查看Topic。单击Topic管理，向Topic：vehicle_raw_data 中写入消息，请参考Kafka开发指南-python文档，此Topic默认老化时间72小时，到期Topic会自动消失，如果逾期请手动创建以vehicle_raw_data命名的Topic。

图2 Topic

图3 查看消息
进入API调试界面。进入华为云共享版API网关控制台 API管理界面，查找新建的API依次单击“更多”—>“调试”。

图4 API管理界面

API调用。方法选用“POST”,在请求体中填入请求体body内容，单击发送请求。

图5 API调用

参数说明：
taskID: 为任务ID, 即本次转换的任务ID；
vinList: 为本次任务指定转换的车架号列表，例如值为["DM666666"]，将DM666666车架号的原始数据转换为csv格式上传至GES；
date: 为本次任务指定转换日期的车辆数据，例如值为2023-05-09，把DM666666车架号2023-05-09原始数据转换为csv格式上传至GES；
hours: 为本次任务指定日期下更细精度的小时数，不传则解析全天的原始数据，例如值为["01","02","03","04","05","06"]，把DM666666车架号2023-05-09 01-06小时的原始数据转换为csv格式上传至GES。

（可选）发布API。进入华为云共享版API网关控制台 API管理界面，查找新建的API单击“发布”，并在API发布页面中，单击“发布”发布API。

图6 进入发布API页面

图7 发布API
登录华为云图引擎服务 GES，单击“图管理”，选择方案本方案创建的图，单击“操作”列的“访问”。

图8 图管理
在图引擎编辑器页面，在Gremlin查询区输入查询语句（请参考Gremlin查询文档获取），按“回车”键执行操作。可以通过查询语句获取点、边、属性等信息，并可以对数据进行修改、局部遍历和属性过滤等操作。

图9 查询图数据