人工智能和云计算带来的技术变革：云计算的起源与发展

    import tensorflow as tf
    import numpy as np
    
    # 生成数据
    x_data = np.random.rand(100).astype(np.float32)
    y_data = x_data * 0.1 + 0.3
    
    # 创建输入、输出占位符
    X = tf.placeholder(tf.float32, shape=[None])
    Y = tf.placeholder(tf.float32, shape=[None])
    
    # 设置模型参数
    w = tf.Variable(tf.zeros([1]))
    b = tf.Variable(tf.zeros([1]))
    
    # 构建线性回归模型
    hypothesis = w*X + b
    
    # 使用均方误差作为损失函数
    cost = tf.reduce_mean(tf.square(hypothesis - Y))
    optimizer = tf.train.GradientDescentOptimizer(learning_rate=0.01)
    train_op = optimizer.minimize(cost)
    
    # 初始化全局变量
    init = tf.global_variables_initializer()
    sess = tf.Session()
    sess.run(init)
    
    # 训练模型
    for step in range(201):
    _, cost_val, w_val, b_val = sess.run([train_op, cost, w, b], feed_dict={X: x_data, Y: y_data})
    if step % 20 == 0:
        print("Step:", step, "Cost:", cost_val, "Weight:", w_val, "Bias:", b_val)
    
    # 测试模型
    print("\nTesting model")
    print("Prediction:", sess.run(hypothesis, feed_dict={X: [1, 2, 3]})) # [0.3695572]
    
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
    
    代码解读

    public static void main(String[] args) throws Exception {
    // 配置
    String inputFile = "/user/hadoop/input/";
    String outputFile = "/user/hadoop/output/";
    
    Configuration conf = new Configuration();
    Job job = Job.getInstance(conf);
    
    // 指定 Mapper 和 Reducer 类
    job.setJarByClass(WordCount.class);
    job.setOutputKeyClass(Text.class);
    job.setOutputValueClass(IntWritable.class);
    
    job.setMapperClass(MyMapper.class);
    job.setReducerClass(MyReducer.class);
    
    // 指定输入路径和输出路径
    FileInputFormat.addInputPath(job, new Path(inputFile));
    FileOutputFormat.setOutputPath(job, new Path(outputFile));
    
    // 执行作业
    System.exit(job.waitForCompletion(true)? 0 : 1);
    }
    
    // Mapper 类
    public static class MyMapper extends Mapper<LongWritable, Text, Text, IntWritable> {
    
    private final static IntWritable one = new IntWritable(1);
    
    @Override
    public void map(LongWritable key, Text value, Context context)
            throws IOException, InterruptedException {
    
        String line = value.toString().toLowerCase();
    
        for (String word : line.split("\ W+")) {
    
            Text outputKey = new Text(word);
            context.write(outputKey, one);
    
        }
    
    }
    
    }
    
    // Reducer 类
    public static class MyReducer extends Reducer<Text, IntWritable, Text, IntWritable> {
    
    @Override
    protected void reduce(Text key, Iterable<IntWritable> values, Context context)
            throws IOException, InterruptedException {
    
        int sum = 0;
    
        for (IntWritable val : values) {
            sum += val.get();
        }
    
        context.write(key, new IntWritable(sum));
    
    }
    
    }
    
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
    
    代码解读

    apiVersion: v1
    kind: Pod
    metadata:
      name: myapp-pod
      labels:
    app: myapp
    spec:
      containers:
      - name: myapp-container
    image: busybox
    command: ['sh', '-c', 'echo start && sleep 10']
    volumeMounts:
    - mountPath: /tmp
      name: tmp-volume
      volumes:
      - name: tmp-volume
    emptyDir: {}
    ---
    apiVersion: batch/v1
    kind: Job
    metadata:
      name: myapp-job
    spec:
      template:
    metadata:
      name: myapp-pod
    spec:
      restartPolicy: Never
      containers:
      - name: myapp-container
        image: busybox
        command: ["sh", "-c", "sleep 2 ; cat /etc/resolv.conf | wc -l"]
        resources:
          limits:
            memory: "64Mi"
            cpu: "50m"
          requests:
            memory: "32Mi"
            cpu: "25m"
      terminationGracePeriodSeconds: 5
    ---
    apiVersion: v1
    kind: Service
    metadata:
      name: myapp-service
    spec:
      selector:
    app: myapp
      ports:
      - protocol: TCP
    port: 80
    targetPort: http
    
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
      
    
    代码解读