实时即未来,车联网项目之创建Flink实时计算子工程
【摘要】 创建Flink实时计算子工程 1 在原工程下创建实时分析子模块总工程结构设计创建StreamingAnalysis工程设置打包类型为:jar 2 导入实时分析子模块pom依赖略l 工程包目录 3 配置实时分析子模块资源文件conf.properties# mysql configurationjdbc.driver=com.mysql.jdbc.Driverjdbc.url=jdbc...
创建Flink实时计算子工程
1 在原工程下创建实时分析子模块
总工程结构设计
创建StreamingAnalysis工程
设置打包类型为:jar
2 导入实时分析子模块pom依赖
略
l 工程包目录
3 配置实时分析子模块资源文件
conf.properties
# mysql configuration
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://node03:3306/vehicle_networking?characterEncoding=utf8&useSSL=false
jdbc.user=root
jdbc.password=123456
jdbc.dataSource.size=10
# hdfsUri
hdfsUri=hdfs://node01:8020
#ZK configuration
zookeeper.clientPort=2181
zookeeper.quorum=node01,node02,node03
# kafka configuration
kafka.topic=vehicledata
bootstrap.servers=node01:9092,node02:9092,node03:9092
# mongoDB configuration
mongo.host=node03
mongo.port=27017
mongo.userName=itcast
mongo.password=itcast
mongo.source=itcast
# redis configuration
redis.host=node03
redis.port=6379
redis.password=null
redis.database=0
redis.session.timeout=1000
redis.key.timeout=900
# vehinfo match sleep millionseconds
vehinfo.millionseconds=18000000
ruleinfo.millionseconds=100000
elerules.millionseconds=300000
logback.xml
注意log4j的jar包冲突问题
<?xml version="0" encoding="UTF-8"?>
<configuration>
<!--http://logback.qos.ch/manual/configuration.html-->
<!--设置日志输出到控制台-->
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<!-- encoder的默认实现类是ch.qos.logback.classic.encoder.PatternLayoutEncoder -->
<encoder>
<pattern>%date %level [%thread] %logger{10} [%file:%line] %msg%n</pattern>
</encoder>
</appender>
<!-- name值可以是包名或具体的类名:该包(包括子包)下的类或该类将采用此logger -->
<logger name="com.john.logging.b" level="INFO" additivity="false">
<appender-ref ref="STDOUT" />
</logger>
<!--设置日志输出为文件-->
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>debug.log</file>
<encoder>
<pattern>%date %level [%thread] %logger{10} [%file:%line] %msg%n</pattern>
</encoder>
</appender>
<!--日志输出级别-->
<root level="DEBUG">
<appender-ref ref="STDOUT" />
<appender-ref ref="FILE" />
</root>
</configuration>
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱:
cloudbbs@huaweicloud.com
- 点赞
- 收藏
- 关注作者
评论(0)