Browse Source

fix:修复go-fast、kafka地址以及资源保存位置

master
steve.gao 5 months ago
parent
commit
decf761dce
  1. 2
      kafka_utils.js
  2. 2
      server.js
  3. 4
      upload_files.js

2
kafka_utils.js

@ -1,5 +1,5 @@
const {Kafka} = require("kafkajs");
const brokers = [] // TODO:测试kafka
const brokers = ["172.16.228.89:19092"] // TODO:测试kafka
/**
*

2
server.js

@ -13,7 +13,7 @@ const utils = require("./utils");
const {push_data, create_kafka_client} = require("./kafka_utils");
const topic_message = "whatsapp_test1";
// const topic_status = "whatsapp_test2";
const user_iphone = '8615201683893@c.us'; // 当前登陆账号手机 用于判断被踢的是不是自己
const user_iphone = '8615201683893@c.us'; // TODO:需要修改当前登陆账号手机 用于判断被踢的是不是自己
// 封装部分日志打印内容 新增日期显示
{

4
upload_files.js

@ -1,8 +1,8 @@
'use strict'
const axios = require('axios');
const fs = require('fs');
const url = ""; // TODO: 上传路径修改
const dir = "/opt/crawl/whatsapp/whatsapp-wppconnect/sources/"
const url = "http://10.8.0.10:8081/group1/upload";
const dir = "/opt/crawl/whatsapp/whatsapp_wppconnect/sources/"

Loading…
Cancel
Save