Hadoop生态圈(二十七)- MapReduce Job提交源码分析
目录
- 1. Debug环境准备
- 1.1 Debug代码:MR经典入门案例WordCount
- 1.1.1 Mapper类
- 1.1.2 Reducer类
- 1.1.3 程序运行的主类
- 2. MapReduce Job提交源码追踪
- 2.1 MapReduce程序入口方法
- 2.2 job.waitForCompletion
- 2.3 job.submit
- 2.3.1 connect
- 2.3.1.1 Cluster
- 2.3.1.2 initialize
- 2.3.2 ClientProtocolProvider
- 2.3.2.1 LocalClientProtocolProvider
- 2.3.2.2 YarnClientProtocolProvider
- 2.3.3 submitJobInternal
1. Debug环境准备
1.1 Debug代码:MR经典入门案例WordCount
1.1.1 Mapper类
public class WordCountMapper extends Mapper<LongWritable, Text,Text,LongWritable> {@Overrideprotected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {String[] words = value.toString().split("\\s+");for (String word : words) {context.write(new Text(word),new LongWritable(1));}}
}
1.1.2 Reducer类
public class WordCountReducer extends Reducer<Text, LongWritable,Text,LongWritable> {@Overrideprotected void reduce(Text key, Iterable<LongWritable> values, Context context) throws IOException, InterruptedException {long count = 0;for (LongWritable value : values) {count +=value.get();}context.write(key,new LongWritable(count));}
}
1.1.3 程序运行的主类
public class WordCountDriver extends Configured implements Tool {@Overridepublic int run(String[] args) throws Exception {// 创建作业实例Job job = Job.getInstance(getConf(), WordCountDriver.class.getSimpleName());// 设置作业驱动类job.setJarByClass(this.getClass());// 设置作业mapper reducer类job.setMapperClass(WordCountMapper.class);job.setReducerClass(WordCountReducer.class);// 设置作业mapper阶段输出key value数据类型job.setMapOutputKeyClass(Text.class);job.setMapOutputValueClass(LongWritable.class);//设置作业reducer阶段输出key value数据类型 也就是程序最终输出数据类型job.setOutputKeyClass(Text.class);job.setOutputValueClass(LongWritable.class);// 配置作业的输入数据路径FileInputFormat.addInputPath(job, new Path(args[0]));// 配置作业的输出数据路径FileOutputFormat.setOutputPath(job, new Path(args[1]));//判断输出路径是否存在 如果存在删除FileSystem fs = FileSystem.get(getConf());if(fs.exists(new Path(args[1]))){fs.delete(new Path(args[1]),true);}// 提交作业并等待执行完成return job.waitForCompletion(true) ? 0 : 1;}public static void main(String[] args) throws Exception {//配置文件对象Configuration conf = new Configuration();//使用工具类ToolRunner提交程序int status = ToolRunner.run(conf, new WordCountDriver(), args);//退出客户端程序 客户端退出状态码和MapReduce程序执行结果绑定System.exit(status);}
}
2. MapReduce Job提交源码追踪
Debug 功能的使用方法可参考:《IntelliJ IDEA Debug工具的使用》
2.1 MapReduce程序入口方法
作为使用 java 语言编写的 MapReduce 程序,其入口方法为 main 方法。在 main 方法中,使用了 ToolRunner 启动运行了 MapReduce客户端主类,其逻辑实现定义在run方法中
。
@Override
public int run(String[] args) throws Exception {// 创建作业实例Job job = Job.getInstance(getConf(), WordCountDriver.class.getSimpleName());// 设置作业驱动类job.setJarByClass(this.getClass());// 设置作业mapper reducer类job.setMapperClass(WordCountMapper.class);job.setReducerClass(WordCountReducer.class);// 设置作业mapper阶段输出key value数据类型job.setMapOutputKeyClass(Text.class);job.setMapOutputValueClass(LongWritable.class);//设置作业reducer阶段输出key value数据类型 也就是程序最终输出数据类型job.setOutputKeyClass(Text.class);job.setOutputValueClass(LongWritable.class);// 配置作业的输入数据路径FileInputFormat.addInputPath(job, new Path(args[0]));// 配置作业的输出数据路径FileOutputFormat.setOutputPath(job, new Path(args[1]));//判断输出路径是否存在 如果存在删除FileSystem fs = FileSystem.get(getConf());if(fs.exists(new Path(args[1]))){fs.delete(new Path(args[1]),true);}// 提交作业并等待执行完成return job.waitForCompletion(true) ? 0 : 1;
}
2.2 job.waitForCompletion
客户端的最后执行了Job.waitForCompletion()
方法,从名字上可以看出该方法的功能是等待 MR 程序执行完毕。进入该方法内部:
在判断状态 state 可以提交 Job 后,执行submit()
方法。monitorAndPrintJob()
方法会不断的刷新获取 job 运行的进度信息,并打印。boolean 参数 verbose 为 true 表明要打印运行进度,为 false 就只是等待 job 运行结束,不打印运行日志。
public boolean waitForCompletion(boolean verbose) throws IOException, InterruptedException,ClassNotFoundException {//当job状态为define时if (state == JobState.DEFINE) {submit();//aw:提交job}if (verbose) {//verbose值由用户指定 boolean类型//aw:随着进度和任务的进行,实时监视作业和打印状态monitorAndPrintJob();} else {// get the completion poll interval from the client.// 从客户端根据轮询间隔(默认5000 ms) 拉取完成状态信息int completionPollIntervalMillis = Job.getCompletionPollInterval(cluster.getConf());while (!isComplete()) {try {Thread.sleep(completionPollIntervalMillis);} catch (InterruptedException ie) {}}}return isSuccessful();//检查作业是否成功完成。返回true表示成功。
}
2.3 job.submit
public void submit() throws IOException, InterruptedException, ClassNotFoundException {//再次检查确保作业状态为defineensureState(JobState.DEFINE);//设置使用新apisetUseNewAPI();//跟程序运行环境建立连接connect();//获取job提交器 根据运行环境分为local提交器、yarn提交器final JobSubmitter submitter = getJobSubmitter(cluster.getFileSystem(), cluster.getClient());status = ugi.doAs(new PrivilegedExceptionAction<JobStatus>() {public JobStatus run() throws IOException, InterruptedException, ClassNotFoundException {return submitter.submitJobInternal(Job.this, cluster);//todo 提交job}});//客户端提交job成功,状态更新为runningstate = JobState.RUNNING;LOG.info("The url to track the job: " + getTrackingURL());
}
2.3.1 connect
MapReduce 作业提交时,连接集群是通过Job的connect()方法实现的
,它实际上是构造集群Cluster实例cluster
。Cluster为连接MapReduce集群的一种工具,提供了一种获取MapReduce集群信息的方法
。
在 Cluster 内部,有一个与集群进行通信的客户端通信协议 ClientProtocol 实例 client,它由 ClientProtocolProvider 的静态 create() 方法构造,而 Hadoop2.x 中提供了两种模式的 ClientProtocol,分别为 Yarn 模式的 YARNRunner 和 Local 模式的 LocalJobRunner,Cluster 实际上是由它们负责与集群进行通信的,而 Yarn 模式下,ClientProtocol 实例 YARNRunner 对象内部有一个 ResourceManager 代理 ResourceMgrDelegate 实例 resMgrDelegate,Yarn 模式下整个 MapReduce 客户端就是由它负责与 Yarn 集群进行通信,完成诸如作业提交、作业状态查询等过程,通过它获取集群的信息。
private synchronized void connect() throws IOException, InterruptedException, ClassNotFoundException {if (cluster == null) {//若cluster空,则构造Cluster实例cluster = ugi.doAs(new PrivilegedExceptionAction<Cluster>() {public Cluster run() throws IOException, InterruptedException, ClassNotFoundException {return new Cluster(getConfiguration());}});}
}
2.3.1.1 Cluster
Cluster 类中最重要的两个成员变量是客户端通信协议提供者ClientProtocolProvider、客户端通信协议ClientProtocol,实例叫做client
,而后者是依托前者的 create() 方法生成的。
在 ClientProtocol 中,定义了很多方法,客户端可以使用这些方法进行 job 的提交、杀死、或是获取一些程序状态信息。
在 Cluster 的构造方法中,完成了初始化的动作。
2.3.1.2 initialize
在 Cluster 类的构造方法中,调用了 initialize 初始化方法。依次取出每个 ClientProtocolProvider,通过其 create() 方法构造 ClientProtocol 实例。如果配置文件没有配置 YARN 信息,则构建 LocalRunner,MR 任务本地运行,如果配置文件有配置 YARN 信息,则构建 YarnRunner,MR 任务在 YARN 集群上运行。
2.3.2 ClientProtocolProvider
上面 create() 方法时提到了两种 ClientProtocolProvider 实现类。
MapReduce 中,ClientProtocolProvider 抽象类的实现共有 YarnClientProtocolProvider、LocalClientProtocolProvider 两种,前者为 Yarn 模式,而后者为 Local 模式。
Cluster 中客户端通信协议 ClientProtocol 实例,要么是 Yarn 模式下的YARNRunner
,要么就是 Local 模式下的LocalJobRunner
。
2.3.2.1 LocalClientProtocolProvider
2.3.2.2 YarnClientProtocolProvider
YARNRunner 中最重要的一个变量就是 ResourceManager 的代理 ResourceMgrDelegate 类型的resMgrDelegate
实例。
Yarn 模式下整个 MapReduce 客户端就是由它负责与 Yarn 集群进行通信,完成诸如作业提交、作业状态查询等过程,通过它获取集群的信息,其内部有一个实例YarnClient
,负责与 Yarn 进行通信,还有 ApplicationId、ApplicationSubmissionContext 等与特定应用程序相关的成员变量。
2.3.3 submitJobInternal
在 submit 方法的最后,调用了提交器submitter.submitJobInternal方法进行任务的提交
。它是提交Job的内部方法,实现了提交 Job 的所有业务逻辑。
JobSubmitter 的类一共有四个类成员变量,分别为:
- 文件系统 FileSystem 实例 jtFs:用于操作作业运行需要的各种文件等;
- 客户端通信协议 ClientProtocol 实例 submitClient:用于与集群交互,完成作业提交、作业状态查询等。
- 提交作业的主机名 submitHostName;
- 提交作业的主机地址 submitHostAddress。
下面就是提交任务的核心代码:
JobStatus submitJobInternal(Job job, Cluster cluster) throws ClassNotFoundException, InterruptedException, IOException {//validate the jobs output specs 检查作业的输出规范的有效性//aw:比如检查输出路径是否配置并且是否存在。正确情况是已经配置且不存在checkSpecs(job);Configuration conf = job.getConfiguration();addMRFrameworkToDistributedCache(conf);//aw:获取作业准备区路径,用于作业及相关资源的提交存放,比如:jar、切片信息、配置信息等//默认是/tmp/hadoop-yarn/staging/提交作业用户名/.stagingPath jobStagingArea = JobSubmissionFiles.getStagingDir(cluster, conf);//configure the command line options correctly on the submitting dfsInetAddress ip = InetAddress.getLocalHost();if (ip != null) {//记录提交作业的主机IP、主机名submitHostAddress = ip.getHostAddress();submitHostName = ip.getHostName();conf.set(MRJobConfig.JOB_SUBMITHOST,submitHostName);conf.set(MRJobConfig.JOB_SUBMITHOSTADDR,submitHostAddress);}//aw: 与运行集群通信,将获取的jobID设置入jobJobID jobId = submitClient.getNewJobID();job.setJobID(jobId);//创建最终作业准备区路径,jobStagingArea后接/jobIDPath submitJobDir = new Path(jobStagingArea, jobId.toString());JobStatus status = null;try {//设置一些作业参数conf.set(MRJobConfig.USER_NAME, UserGroupInformation.getCurrentUser().getShortUserName());conf.set("hadoop.http.filter.initializers", "org.apache.hadoop.yarn.server.webproxy.amfilter.AmFilterInitializer");conf.set(MRJobConfig.MAPREDUCE_JOB_DIR, submitJobDir.toString());LOG.debug("Configuring job " + jobId + " with " + submitJobDir + " as the submit dir");// get delegation token for the dir 获得路径的授权令牌TokenCache.obtainTokensForNamenodes(job.getCredentials(), new Path[] { submitJobDir }, conf);populateTokenCache(conf, job.getCredentials());// generate a secret to authenticate shuffle transfersif (TokenCache.getShuffleSecretKey(job.getCredentials()) == null) {KeyGenerator keyGen;try {keyGen = KeyGenerator.getInstance(SHUFFLE_KEYGEN_ALGORITHM);keyGen.init(SHUFFLE_KEY_LENGTH);} catch (NoSuchAlgorithmException e) {throw new IOException("Error generating shuffle secret key", e);}SecretKey shuffleKey = keyGen.generateKey();TokenCache.setShuffleSecretKey(shuffleKey.getEncoded(), job.getCredentials());}if (CryptoUtils.isEncryptedSpillEnabled(conf)) {conf.setInt(MRJobConfig.MR_AM_MAX_ATTEMPTS, 1);LOG.warn("Max job attempts set to 1 since encrypted intermediate" + "data spill is enabled");}//aw:拷贝作业相关的资源文件到submitJobDir作业准备区,比如:-libjars,-files,-archivescopyAndConfigureFiles(job, submitJobDir);//创建文件job.xml 用于保存作业的配置信息Path submitJobFile = JobSubmissionFiles.getJobConfPath(submitJobDir);// Create the splits for the job todoLOG.debug("Creating splits at " + jtFs.makeQualified(submitJobDir));//aw:生成本次作业的输入切片信息,并把切片信息写入作业准备区submitJobDirint maps = writeSplits(job, submitJobDir);conf.setInt(MRJobConfig.NUM_MAPS, maps);LOG.info("number of splits:" + maps);int maxMaps = conf.getInt(MRJobConfig.JOB_MAX_MAP, MRJobConfig.DEFAULT_JOB_MAX_MAP);if (maxMaps >= 0 && maxMaps < maps) {throw new IllegalArgumentException("The number of map tasks " + maps + " exceeded limit " + maxMaps);}// write "queue admins of the queue to which job is being submitted"// to job file.队列信息String queue = conf.get(MRJobConfig.QUEUE_NAME, JobConf.DEFAULT_QUEUE_NAME);AccessControlList acl = submitClient.getQueueAdmins(queue);conf.set(toFullPropertyName(queue, QueueACL.ADMINISTER_JOBS.getAclName()), acl.getAclString());// removing jobtoken referrals before copying the jobconf to HDFS// as the tasks don't need this setting, actually they may break// because of it if present as the referral will point to a// different job.TokenCache.cleanUpTokenReferral(conf);if (conf.getBoolean(MRJobConfig.JOB_TOKEN_TRACKING_IDS_ENABLED,MRJobConfig.DEFAULT_JOB_TOKEN_TRACKING_IDS_ENABLED)) {// Add HDFS tracking idsArrayList<String> trackingIds = new ArrayList<String>();for (Token<? extends TokenIdentifier> t : job.getCredentials().getAllTokens()) {trackingIds.add(t.decodeIdentifier().getTrackingId());}conf.setStrings(MRJobConfig.JOB_TOKEN_TRACKING_IDS, trackingIds.toArray(new String[trackingIds.size()]));}// Set reservation info if it existsReservationId reservationId = job.getReservationId();if (reservationId != null) {conf.set(MRJobConfig.RESERVATION_ID, reservationId.toString());}// 把作业配置信息写入作业准备区的job.xml文件中writeConf(conf, submitJobFile);//// Now, actually submit the job (using the submit name)//printTokens(jobId, job.getCredentials());//aw:到这里,终于进行真正的作用提交了status = submitClient.submitJob(jobId, submitJobDir.toString(), job.getCredentials());if (status != null) {return status;} else {throw new IOException("Could not launch job");}} finally {if (status == null) {LOG.info("Cleaning up the staging area " + submitJobDir);if (jtFs != null && submitJobDir != null)jtFs.delete(submitJobDir, true);}}
}
如若内容造成侵权/违法违规/事实不符,请联系编程学习网邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
相关文章
- koa2 使用 Joi
封装函数: const { ErrorModel } require("../model/resModel"); function schema(method, schemas) {async function validateSchema(ctx, next) {let data null;if (method "get") {data await ctx.request.query;} else {data await c…...
2024/4/13 23:57:23 - 【STC15】定时器/计数器的相关寄存器解读
【STC15】定时器/计数器的相关寄存器解读说明:资料来源于STC官方STC15手册。 STC15定时器相关寄存器 定时器/计数器0/1控制寄存器:TCON TCON为定时器/计数器T0、T1的控制寄存器,同时也锁存T0、T1溢出中断源和外部请求中断源等,TCON格式如下&…...
2024/4/13 14:19:48 - SQL五十道经典题型——(五)查询没学过“张三”老师课的学生的学号、姓名(重点)
查询没学过“张三”老师课的学生的学号、姓名(重点) 解题思路 重点:分析各个表之前对应的关系。score分数表将各个科目与学生id相关联, 第一步,在 teacher 表中获取“张三”老师的 t_id , 第二步࿰…...
2024/4/19 8:07:26 - 【李守聪原创】攻坚克难,梦在远方
正是因为心怀蓝天,雏鹰临崖才飞上天空;正是因为期待晨曦,丛叶露珠才光芒闪耀;正是因为梦在远方,追梦人才攻坚克难。 梦想之所以成为梦想就在于与现实的差距。梦想越大,困难越大,但发展的空间也越…...
2024/4/19 4:40:06 - web前端学习day-04
1 css常用属性 1 background-color 设置元素的背景颜色 2 background-image 设置元素的背景图像 3 background-repeat 设置是否及如何重复背景图像 2 文本 color 颜色 text-align 设置文本对齐方式 :center left right justify(两端对齐࿰…...
2024/5/2 9:36:02 - CAD画图软件源码
CAD画图软件源码 1.采用c#编程语言编写。 2.可以导入dxf文件编辑保存。 3.支持画板放大缩小平移 4.实现图形绘制,角点,平移,旋转,镜像等操作 5.完整源代码,规范的编程风格。编号:5825645369795909c***y...
2024/4/13 14:19:33 - java使用web3j,部署智能合约在测试链上,并调用(详细教程)
目录前言一、准备工作二、智能合约的编写三、用java完成web3j调用(一)、生成对应合约的bin 以及 abi 文件(二)、利用abi,bin文件生成solidity的java代码(三)、(部署)调用合约上的函数…...
2024/4/30 9:58:27 - [渝粤教育] 南京师范大学中北学院 C语言程序设计 参考 资料
教育 -C语言程序设计-章节资料考试资料-南京师范大学中北学院【】 第一章 单元测试 1、【单选题】对于计算机来说,最后执行的C语言程序是( ) A、源程序 B、目标程序 C、汇编程序 D、可执行程序 参考资料【 】 2、【单选题】以下叙述中正确的是…...
2024/4/27 8:00:05 - Spark学习笔记[1]-scala环境安装与基本语法
Spark学习笔记[1]-scala环境安装与基本语法 正所谓工欲善其事必先利其器,Spark的开发语言不是java而是scala,虽然都是运行于JVM,但是两门语言的基本特性还是有些不一样,这里说明一个概念,JVM不等于JAVA,任何…...
2024/4/27 9:34:28 - Day530.图灵学院之面试题④ -面经
图灵学院之面试题④ 1、双亲委派机制 2、Java中的异常体系 3、sleep()、wait()、join()、yield()的区别是什么? 4、说说你对线程安全的理解 5、Thread和Runnable的区别 6、说说你对守护线程的理解 7、ThreadLocal原理和使用场景 8、并发、并行、串行的区别 9、简述…...
2024/4/30 9:58:15 - 解决Electron应用打开后短暂出现菜单栏和白屏闪烁问题
问题背景: 最近准备使用Electron来做一个桌面读书软件,由于之前接触出类似项目,但没有人深入去做,所以这次准备自己独立完成一个。 Electron打包的应用会自带上顶部菜单栏,包括(File、Edit、View、Window、…...
2024/4/7 21:20:14 - 【JAVA异常处理 | try-catch、throw、throws】
异常 一般异常代码: public class Exception01 {public static void main(String[] args) {int n1 10;int n2 0;// n1 / n2 > 10 / 0int res n1/n2;System.out.println("程序继续运行……");} }设置了异常捕获(try-catch): public cl…...
2024/4/28 21:53:43 - SpringBoot整合JPA
SpringBoot整合JPA JPA是什么? JPA (Java Persistence API)Java持久化API。是一套Sun公司Java官方制定的ORM 方案,是规范,是标准 ,sun公司自己并没有实现 导入Maven <dependency><groupId>org.springframework.boot&…...
2024/4/13 14:19:33 - leetcode--最后一个单词的长度
题目:给你一个字符串 s,由若干单词组成,单词前后用一些空格字符隔开。返回字符串中最后一个单词的长度。 单词 是指仅由字母组成、不包含任何空格字符的最大子字符串。1示例: # 示例 1 输入:s "Hello World&quo…...
2024/4/7 21:20:11 - python利用Monte Carlo方法计算圆周率
from random import randomdef cal(n):count 0for i in range(1, n):x random()y random()if x*x y*y < 1:count 1print("pi:", 4*count/n)if __name__ __main__:cal(10000000)参考文献 蒙特卡洛(Monte Carlo, MCMC)方法…...
2024/4/13 14:19:13 - 结构体与共用体
1.1结构体类型 c语言提供了一种称为结构体的数据类型,可以将同一个对象的不同类型的数据组织在一个有联系的群体里。可以定义一种结构体类型,将属于同一个对象的不同类型的成员组合在一起,形成结构体类型,然后再定义该结构体类型…...
2024/4/7 21:20:10 - 消息中间件RabbitMQ(五)——实现RPC调用
文章目录1. RPC2. 实现原理3. 代码实现3.1 客户端实现3.2 服务端实现3.3 测试4. 小结1. RPC 对于微服务开发者,对于 RPC(Remote Procedure Call Protocol 远程过程调用协议)并不会陌生吧, RESTful API、Dubbo、WebService等都是R…...
2024/4/30 9:57:25 - 前端交互、前后端交互、数据格式转换基础相关知识
目录 前端交互简单基础 前后端交互、数据格式转换 快速上手第一个flask应用小应用 例2flask应用:将当前目录下的文件(文件或者文件夹)以文本形式显示出来 数据格式转换 前端用AJAX发送请求 前端交互简单基础 前端交互主要应用HTML DOM事…...
2024/4/13 14:20:13 - docker容器中的soket与宿主机soket实现网络通信
前言: 如果都是在服务器上,直接主机127.0.0.1端口通信即可 但是我有一个python端soket是安装在了容器内,而我另一个在服务器本身,测试的时候无法实现通信 正文 后来查询了各种办法,端口映射也做了,也还是无…...
2024/4/30 9:57:36 - sql注入学习笔记1
目录 SQL注入分类 SQL基本注入语句 [极客大挑战 2019]EASYSQL 堆叠注入知识汇总 1,[强网杯 2019]随便注 2,[SUCTF 2019]EasySQL WP 其余例题 [极客大挑战2019]LoveSQL [极客大挑战2019]BabySQL(双写绕过) 报错注入知识汇总 sqli-labs练习 Less-1 基于单…...
2024/5/3 22:41:36
最新文章
- YApi的在IDEA中的使用
1 IDEA中插件下载 2 misc.xml的配置 <component name"yapi"><option name"projectToken">XXXXXXXXXX</option><option name"projectId">47</option><option name"yapiUrl">http://XXXX:3000<…...
2024/5/6 15:22:08 - 梯度消失和梯度爆炸的一些处理方法
在这里是记录一下梯度消失或梯度爆炸的一些处理技巧。全当学习总结了如有错误还请留言,在此感激不尽。 权重和梯度的更新公式如下: w w − η ⋅ ∇ w w w - \eta \cdot \nabla w ww−η⋅∇w 个人通俗的理解梯度消失就是网络模型在反向求导的时候出…...
2024/5/6 9:38:23 - 基于AI智能识别技术的智慧展览馆视频监管方案设计
一、建设背景 随着科技的不断进步和社会安全需求的日益增长,展览馆作为展示文化、艺术和科技成果的重要场所,其安全监控系统的智能化升级已成为当务之急。为此,旭帆科技(TSINGSEE青犀)基于视频智能分析技术推出了展览…...
2024/5/4 13:13:49 - 数据结构——二叉树——二叉搜索树(Binary Search Tree, BST)
目录 一、98. 验证二叉搜索树 二、96. 不同的二叉搜索树 三、538. 把二叉搜索树转换为累加树 二叉搜索树:对于二叉搜索树中的每个结点,其左子结点的值小于该结点的值,而右子结点的值大于该结点的值 一、98. 验证二叉搜索树 给你一个二叉树的…...
2024/5/5 17:26:06 - 【外汇早评】美通胀数据走低,美元调整
原标题:【外汇早评】美通胀数据走低,美元调整昨日美国方面公布了新一期的核心PCE物价指数数据,同比增长1.6%,低于前值和预期值的1.7%,距离美联储的通胀目标2%继续走低,通胀压力较低,且此前美国一季度GDP初值中的消费部分下滑明显,因此市场对美联储后续更可能降息的政策…...
2024/5/4 23:54:56 - 【原油贵金属周评】原油多头拥挤,价格调整
原标题:【原油贵金属周评】原油多头拥挤,价格调整本周国际劳动节,我们喜迎四天假期,但是整个金融市场确实流动性充沛,大事频发,各个商品波动剧烈。美国方面,在本周四凌晨公布5月份的利率决议和新闻发布会,维持联邦基金利率在2.25%-2.50%不变,符合市场预期。同时美联储…...
2024/5/4 23:54:56 - 【外汇周评】靓丽非农不及疲软通胀影响
原标题:【外汇周评】靓丽非农不及疲软通胀影响在刚结束的周五,美国方面公布了新一期的非农就业数据,大幅好于前值和预期,新增就业重新回到20万以上。具体数据: 美国4月非农就业人口变动 26.3万人,预期 19万人,前值 19.6万人。 美国4月失业率 3.6%,预期 3.8%,前值 3…...
2024/5/4 23:54:56 - 【原油贵金属早评】库存继续增加,油价收跌
原标题:【原油贵金属早评】库存继续增加,油价收跌周三清晨公布美国当周API原油库存数据,上周原油库存增加281万桶至4.692亿桶,增幅超过预期的74.4万桶。且有消息人士称,沙特阿美据悉将于6月向亚洲炼油厂额外出售更多原油,印度炼油商预计将每日获得至多20万桶的额外原油供…...
2024/5/6 9:21:00 - 【外汇早评】日本央行会议纪要不改日元强势
原标题:【外汇早评】日本央行会议纪要不改日元强势近两日日元大幅走强与近期市场风险情绪上升,避险资金回流日元有关,也与前一段时间的美日贸易谈判给日本缓冲期,日本方面对汇率问题也避免继续贬值有关。虽然今日早间日本央行公布的利率会议纪要仍然是支持宽松政策,但这符…...
2024/5/4 23:54:56 - 【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响
原标题:【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响近日伊朗局势升温,导致市场担忧影响原油供给,油价试图反弹。此时OPEC表态稳定市场。据消息人士透露,沙特6月石油出口料将低于700万桶/日,沙特已经收到石油消费国提出的6月份扩大出口的“适度要求”,沙特将满…...
2024/5/4 23:55:05 - 【外汇早评】美欲与伊朗重谈协议
原标题:【外汇早评】美欲与伊朗重谈协议美国对伊朗的制裁遭到伊朗的抗议,昨日伊朗方面提出将部分退出伊核协议。而此行为又遭到欧洲方面对伊朗的谴责和警告,伊朗外长昨日回应称,欧洲国家履行它们的义务,伊核协议就能保证存续。据传闻伊朗的导弹已经对准了以色列和美国的航…...
2024/5/4 23:54:56 - 【原油贵金属早评】波动率飙升,市场情绪动荡
原标题:【原油贵金属早评】波动率飙升,市场情绪动荡因中美贸易谈判不安情绪影响,金融市场各资产品种出现明显的波动。随着美国与中方开启第十一轮谈判之际,美国按照既定计划向中国2000亿商品征收25%的关税,市场情绪有所平复,已经开始接受这一事实。虽然波动率-恐慌指数VI…...
2024/5/4 23:55:16 - 【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试
原标题:【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试美国和伊朗的局势继续升温,市场风险情绪上升,避险黄金有向上突破阻力的迹象。原油方面稍显平稳,近期美国和OPEC加大供给及市场需求回落的影响,伊朗局势并未推升油价走强。近期中美贸易谈判摩擦再度升级,美国对中…...
2024/5/4 23:54:56 - 【原油贵金属早评】市场情绪继续恶化,黄金上破
原标题:【原油贵金属早评】市场情绪继续恶化,黄金上破周初中国针对于美国加征关税的进行的反制措施引发市场情绪的大幅波动,人民币汇率出现大幅的贬值动能,金融市场受到非常明显的冲击。尤其是波动率起来之后,对于股市的表现尤其不安。隔夜美国股市出现明显的下行走势,这…...
2024/5/6 1:40:42 - 【外汇早评】美伊僵持,风险情绪继续升温
原标题:【外汇早评】美伊僵持,风险情绪继续升温昨日沙特两艘油轮再次发生爆炸事件,导致波斯湾局势进一步恶化,市场担忧美伊可能会出现摩擦生火,避险品种获得支撑,黄金和日元大幅走强。美指受中美贸易问题影响而在低位震荡。继5月12日,四艘商船在阿联酋领海附近的阿曼湾、…...
2024/5/4 23:54:56 - 【原油贵金属早评】贸易冲突导致需求低迷,油价弱势
原标题:【原油贵金属早评】贸易冲突导致需求低迷,油价弱势近日虽然伊朗局势升温,中东地区几起油船被袭击事件影响,但油价并未走高,而是出于调整结构中。由于市场预期局势失控的可能性较低,而中美贸易问题导致的全球经济衰退风险更大,需求会持续低迷,因此油价调整压力较…...
2024/5/4 23:55:17 - 氧生福地 玩美北湖(上)——为时光守候两千年
原标题:氧生福地 玩美北湖(上)——为时光守候两千年一次说走就走的旅行,只有一张高铁票的距离~ 所以,湖南郴州,我来了~ 从广州南站出发,一个半小时就到达郴州西站了。在动车上,同时改票的南风兄和我居然被分到了一个车厢,所以一路非常愉快地聊了过来。 挺好,最起…...
2024/5/4 23:55:06 - 氧生福地 玩美北湖(中)——永春梯田里的美与鲜
原标题:氧生福地 玩美北湖(中)——永春梯田里的美与鲜一觉醒来,因为大家太爱“美”照,在柳毅山庄去寻找龙女而错过了早餐时间。近十点,向导坏坏还是带着饥肠辘辘的我们去吃郴州最富有盛名的“鱼头粉”。说这是“十二分推荐”,到郴州必吃的美食之一。 哇塞!那个味美香甜…...
2024/5/4 23:54:56 - 氧生福地 玩美北湖(下)——奔跑吧骚年!
原标题:氧生福地 玩美北湖(下)——奔跑吧骚年!让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 啊……啊……啊 两…...
2024/5/4 23:55:06 - 扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!
原标题:扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!扒开伪装医用面膜,翻六倍价格宰客!当行业里的某一品项火爆了,就会有很多商家蹭热度,装逼忽悠,最近火爆朋友圈的医用面膜,被沾上了污点,到底怎么回事呢? “比普通面膜安全、效果好!痘痘、痘印、敏感肌都能用…...
2024/5/5 8:13:33 - 「发现」铁皮石斛仙草之神奇功效用于医用面膜
原标题:「发现」铁皮石斛仙草之神奇功效用于医用面膜丽彦妆铁皮石斛医用面膜|石斛多糖无菌修护补水贴19大优势: 1、铁皮石斛:自唐宋以来,一直被列为皇室贡品,铁皮石斛生于海拔1600米的悬崖峭壁之上,繁殖力差,产量极低,所以古代仅供皇室、贵族享用 2、铁皮石斛自古民间…...
2024/5/4 23:55:16 - 丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者
原标题:丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者【公司简介】 广州华彬企业隶属香港华彬集团有限公司,专注美业21年,其旗下品牌: 「圣茵美」私密荷尔蒙抗衰,产后修复 「圣仪轩」私密荷尔蒙抗衰,产后修复 「花茵莳」私密荷尔蒙抗衰,产后修复 「丽彦妆」专注医学护…...
2024/5/4 23:54:58 - 广州械字号面膜生产厂家OEM/ODM4项须知!
原标题:广州械字号面膜生产厂家OEM/ODM4项须知!广州械字号面膜生产厂家OEM/ODM流程及注意事项解读: 械字号医用面膜,其实在我国并没有严格的定义,通常我们说的医美面膜指的应该是一种「医用敷料」,也就是说,医用面膜其实算作「医疗器械」的一种,又称「医用冷敷贴」。 …...
2024/5/4 23:55:01 - 械字号医用眼膜缓解用眼过度到底有无作用?
原标题:械字号医用眼膜缓解用眼过度到底有无作用?医用眼膜/械字号眼膜/医用冷敷眼贴 凝胶层为亲水高分子材料,含70%以上的水分。体表皮肤温度传导到本产品的凝胶层,热量被凝胶内水分子吸收,通过水分的蒸发带走大量的热量,可迅速地降低体表皮肤局部温度,减轻局部皮肤的灼…...
2024/5/4 23:54:56 - 配置失败还原请勿关闭计算机,电脑开机屏幕上面显示,配置失败还原更改 请勿关闭计算机 开不了机 这个问题怎么办...
解析如下:1、长按电脑电源键直至关机,然后再按一次电源健重启电脑,按F8健进入安全模式2、安全模式下进入Windows系统桌面后,按住“winR”打开运行窗口,输入“services.msc”打开服务设置3、在服务界面,选中…...
2022/11/19 21:17:18 - 错误使用 reshape要执行 RESHAPE,请勿更改元素数目。
%读入6幅图像(每一幅图像的大小是564*564) f1 imread(WashingtonDC_Band1_564.tif); subplot(3,2,1),imshow(f1); f2 imread(WashingtonDC_Band2_564.tif); subplot(3,2,2),imshow(f2); f3 imread(WashingtonDC_Band3_564.tif); subplot(3,2,3),imsho…...
2022/11/19 21:17:16 - 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机...
win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”问题的解决方法在win7系统关机时如果有升级系统的或者其他需要会直接进入一个 等待界面,在等待界面中我们需要等待操作结束才能关机,虽然这比较麻烦,但是对系统进行配置和升级…...
2022/11/19 21:17:15 - 台式电脑显示配置100%请勿关闭计算机,“准备配置windows 请勿关闭计算机”的解决方法...
有不少用户在重装Win7系统或更新系统后会遇到“准备配置windows,请勿关闭计算机”的提示,要过很久才能进入系统,有的用户甚至几个小时也无法进入,下面就教大家这个问题的解决方法。第一种方法:我们首先在左下角的“开始…...
2022/11/19 21:17:14 - win7 正在配置 请勿关闭计算机,怎么办Win7开机显示正在配置Windows Update请勿关机...
置信有很多用户都跟小编一样遇到过这样的问题,电脑时发现开机屏幕显现“正在配置Windows Update,请勿关机”(如下图所示),而且还需求等大约5分钟才干进入系统。这是怎样回事呢?一切都是正常操作的,为什么开时机呈现“正…...
2022/11/19 21:17:13 - 准备配置windows 请勿关闭计算机 蓝屏,Win7开机总是出现提示“配置Windows请勿关机”...
Win7系统开机启动时总是出现“配置Windows请勿关机”的提示,没过几秒后电脑自动重启,每次开机都这样无法进入系统,此时碰到这种现象的用户就可以使用以下5种方法解决问题。方法一:开机按下F8,在出现的Windows高级启动选…...
2022/11/19 21:17:12 - 准备windows请勿关闭计算机要多久,windows10系统提示正在准备windows请勿关闭计算机怎么办...
有不少windows10系统用户反映说碰到这样一个情况,就是电脑提示正在准备windows请勿关闭计算机,碰到这样的问题该怎么解决呢,现在小编就给大家分享一下windows10系统提示正在准备windows请勿关闭计算机的具体第一种方法:1、2、依次…...
2022/11/19 21:17:11 - 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”的解决方法...
今天和大家分享一下win7系统重装了Win7旗舰版系统后,每次关机的时候桌面上都会显示一个“配置Windows Update的界面,提示请勿关闭计算机”,每次停留好几分钟才能正常关机,导致什么情况引起的呢?出现配置Windows Update…...
2022/11/19 21:17:10 - 电脑桌面一直是清理请关闭计算机,windows7一直卡在清理 请勿关闭计算机-win7清理请勿关机,win7配置更新35%不动...
只能是等着,别无他法。说是卡着如果你看硬盘灯应该在读写。如果从 Win 10 无法正常回滚,只能是考虑备份数据后重装系统了。解决来方案一:管理员运行cmd:net stop WuAuServcd %windir%ren SoftwareDistribution SDoldnet start WuA…...
2022/11/19 21:17:09 - 计算机配置更新不起,电脑提示“配置Windows Update请勿关闭计算机”怎么办?
原标题:电脑提示“配置Windows Update请勿关闭计算机”怎么办?win7系统中在开机与关闭的时候总是显示“配置windows update请勿关闭计算机”相信有不少朋友都曾遇到过一次两次还能忍但经常遇到就叫人感到心烦了遇到这种问题怎么办呢?一般的方…...
2022/11/19 21:17:08 - 计算机正在配置无法关机,关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机...
关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容,让我们赶快一起来看一下吧!关机提示 windows7 正在配…...
2022/11/19 21:17:05 - 钉钉提示请勿通过开发者调试模式_钉钉请勿通过开发者调试模式是真的吗好不好用...
钉钉请勿通过开发者调试模式是真的吗好不好用 更新时间:2020-04-20 22:24:19 浏览次数:729次 区域: 南阳 > 卧龙 列举网提醒您:为保障您的权益,请不要提前支付任何费用! 虚拟位置外设器!!轨迹模拟&虚拟位置外设神器 专业用于:钉钉,外勤365,红圈通,企业微信和…...
2022/11/19 21:17:05 - 配置失败还原请勿关闭计算机怎么办,win7系统出现“配置windows update失败 还原更改 请勿关闭计算机”,长时间没反应,无法进入系统的解决方案...
前几天班里有位学生电脑(windows 7系统)出问题了,具体表现是开机时一直停留在“配置windows update失败 还原更改 请勿关闭计算机”这个界面,长时间没反应,无法进入系统。这个问题原来帮其他同学也解决过,网上搜了不少资料&#x…...
2022/11/19 21:17:04 - 一个电脑无法关闭计算机你应该怎么办,电脑显示“清理请勿关闭计算机”怎么办?...
本文为你提供了3个有效解决电脑显示“清理请勿关闭计算机”问题的方法,并在最后教给你1种保护系统安全的好方法,一起来看看!电脑出现“清理请勿关闭计算机”在Windows 7(SP1)和Windows Server 2008 R2 SP1中,添加了1个新功能在“磁…...
2022/11/19 21:17:03 - 请勿关闭计算机还原更改要多久,电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机怎么办...
许多用户在长期不使用电脑的时候,开启电脑发现电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机。。.这要怎么办呢?下面小编就带着大家一起看看吧!如果能够正常进入系统,建议您暂时移…...
2022/11/19 21:17:02 - 还原更改请勿关闭计算机 要多久,配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以...
配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容,让我们赶快一起来看一下吧!配置windows update失败 还原更改 请勿关闭计算机&#x…...
2022/11/19 21:17:01 - 电脑配置中请勿关闭计算机怎么办,准备配置windows请勿关闭计算机一直显示怎么办【图解】...
不知道大家有没有遇到过这样的一个问题,就是我们的win7系统在关机的时候,总是喜欢显示“准备配置windows,请勿关机”这样的一个页面,没有什么大碍,但是如果一直等着的话就要两个小时甚至更久都关不了机,非常…...
2022/11/19 21:17:00 - 正在准备配置请勿关闭计算机,正在准备配置windows请勿关闭计算机时间长了解决教程...
当电脑出现正在准备配置windows请勿关闭计算机时,一般是您正对windows进行升级,但是这个要是长时间没有反应,我们不能再傻等下去了。可能是电脑出了别的问题了,来看看教程的说法。正在准备配置windows请勿关闭计算机时间长了方法一…...
2022/11/19 21:16:59 - 配置失败还原请勿关闭计算机,配置Windows Update失败,还原更改请勿关闭计算机...
我们使用电脑的过程中有时会遇到这种情况,当我们打开电脑之后,发现一直停留在一个界面:“配置Windows Update失败,还原更改请勿关闭计算机”,等了许久还是无法进入系统。如果我们遇到此类问题应该如何解决呢࿰…...
2022/11/19 21:16:58 - 如何在iPhone上关闭“请勿打扰”
Apple’s “Do Not Disturb While Driving” is a potentially lifesaving iPhone feature, but it doesn’t always turn on automatically at the appropriate time. For example, you might be a passenger in a moving car, but your iPhone may think you’re the one dri…...
2022/11/19 21:16:57