小编ram*_*amu的帖子

我们如何使用API​​从IDE在Kafka中创建主题,因为当我这样做时:

bin/kafka-create-topic.sh --topic mytopic --replica 3 --zookeeper localhost:2181

我收到错误:

bash: bin/kafka-create-topic.sh: No such file or directory

我按照原样关注了开发人员设置.

我试图在python中使用Queue,这将是多线程的.我只是想知道我使用的方法是否正确.如果我正在做一些多余的事情或者如果有更好的方法我应该使用.

我试图从表中获取新请求,并使用某些逻辑来安排它们执行某些操作,如运行查询.

所以这里从主线程我为队列生成一个单独的线程.

if __name__=='__main__':

  request_queue = SetQueue(maxsize=-1)
  worker = Thread(target=request_queue.process_queue)
  worker.setDaemon(True)
  worker.start()


  while True:
    try:
      #Connect to the database get all the new requests to be verified
      db = Database(username_testschema, password_testschema, mother_host_testschema, mother_port_testschema, mother_sid_testschema, 0)
      #Get new requests for verification
      verify_these = db.query("SELECT JOB_ID FROM %s.table WHERE     JOB_STATUS='%s' ORDER BY JOB_ID" %
                             (username_testschema, 'INITIATED'))

      #If there are some requests to be verified, put them in the queue.
      if len(verify_these) > 0:
        for row in verify_these:
          print "verifying : %s" …

所以,假设我在一个存储桶下创建了一些记录/文档,并且用户只更新了RDBMS中的一列中的一列,所以我试图只发送那一列数据并在couchbase中更新它.但问题是,couchbase会覆盖整个记录并为其余列添加NULL.

一种方法是在从Cbase获取数据后从现有记录中复制所有数据,然后在复制旧数据时覆盖新列.但这看起来不是一种最佳方法

有什么建议？

我想登录,谁登录使用FLASK的应用程序.我尝试使用, @app.before_request但问题是我需要访问通过烧瓶全局变量的用户名,如果我使用这个装饰器我得不到.

此外,使用如下的全局变量也不起作用.如何在请求上下文中获取全局变量？

import logging
import time
from flask import request, flash
from flask import g
from forms import QueryForm, RequestForm, Approve_Reject_Btn_Form
from query.sqlQuery import SQLQuery
from database.oracle import Database
import datetime
from requests import Session

logger = logging.getLogger(__name__)
login_count = 0
'''
Homepage route - Displays all the tables in the homepage
'''
@app.route('/')
@app.route('/index')
def index():
  try:
    if not g.identity.is_authenticated():
      return render_template('homepage.html')
    else:
      try:
        global login_count
        if login_count == 0:
          username = g.identity.name
          user_ip = request.headers.get('IP_header')
          current_time …