小编BAE*_*BAE的帖子

在我的 Django 视图文件中，我需要从元组列表生成一个 CSV 文件，并将该 CSV 文件存储到我的模型的 FileField 中。

class Bill(models.Model):
    billId = models.IntegerField()
    bill = models.FileField(upload_to='bills')

我在这个网站上搜索，发现了一些帖子，例如Django - 如何创建文件并将其保存到模型的 FileField？，但解决方案可以帮助我。

我需要将CSV文件存储在'media/bills/'文件夹中，我希望CSV文件可以与数据库中的Bill对象一起删除。

我尝试了以下代码，但无法满足我的要求。对于每个文件，它将生成两个文件“output.csv”和“output_xxesss.csv”。通过调用'Bill.objects.all().delete()'不能删除这两个文件。

path = join(settings.MEDIA_ROOT, 'bills', 'output.csv')
print path
f = open(path, 'w+b')
f.truncate()
csvWriter = csv.writer(f)
csvWriter.writerow(('A', 'B', 'C'))
for r in rs:
    print r
    csvWriter.writerow(convert(r))

bill = Bill()
bill.billId = 14
bill.bill.save('output.csv', File(f))
bill.save()

谢谢

我尝试了以下代码，但无法通过调用“Bill.objects.all().delete()”来删除文件。

bill = Bill()
bill.billId = 14
bill.bill.name = 'bills/output.csv'
bill.save()

我正在使用 MySQLdb ( http://mysql-python.sourceforge.net/ )。似乎 connection.open 和 connection.sqlstate() 对我不起作用。下面是代码：

def open(self):
    #TODO: check the connection's status
    # self.__conn.open OR self.__conn.sqlstate()
    try:
        print "sqlstate:"+str( self.__conn.sqlstate() )
        print "open?"+str( self.__conn.open )
        return "00000" == self.__conn.sqlstate()
    except Exception as e:
        print "Exception while checking MYSQL Connection:"+str(e) 
        return False

但是当我运行“sudo service mysql stop; sleep 60; sudo service mysql start;”时 做测试。输出如下。以下输出似乎永远重复了（我最终终止了该过程）。服务器宕机时，connection.open 为1，connection.sqlstate() 为00000。但服务器启动时，connection.executemany() 仍会抛出异常。有任何想法吗？谢谢。

...
    2015-10-20 14:09:06 Exception while executing statement:(2006, 'MySQL server has gone away')
    2015-10-20 14:09:06 sqlstate:00000
    2015-10-20 14:09:06 open?1
    2015-10-20 14:09:06 Reconnected …

~/spark/spark-2.1.1-bin-hadoop2.7/bin$ ./spark-submit --master spark://192.168.42.80:32141 --deploy-mode cluster file:///home/me/workspace/myproj/target/scala-2.11/myproj-assembly-0.1.0.jar

Running Spark using the REST application submission protocol.
Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties
17/06/20 16:41:30 INFO RestSubmissionClient: Submitting a request to launch an application in spark://192.168.42.80:32141.
17/06/20 16:41:31 INFO RestSubmissionClient: Submission successfully created as driver-20170620204130-0005. Polling submission state...
17/06/20 16:41:31 INFO RestSubmissionClient: Submitting a request for the status of submission driver-20170620204130-0005 in spark://192.168.42.80:32141.
17/06/20 16:41:31 INFO RestSubmissionClient: State of driver driver-20170620204130-0005 is now ERROR.
17/06/20 16:41:31 INFO RestSubmissionClient: Driver is running on …

我定义了一个数据类型及其 API：

public class DataType {
    @Column
    private String name;
}

// API is:
public class DataTypeAPI {
    @POST
    @Path("/")
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    @ManagedAsync
    public void createDataType(
            final DataType dataType,
    ) {
        ...
        asyncResponse.resume(Response.status(Response.Status.CREATED)
                .entity(dataType)
                .build());
    }
}

{ "name": "xxx" }只要我摆好姿势一切都好

但当我发帖时{ "name1": "xxx" }，我得到了以下text/plain回复：

Unrecognized field "name1" (class com.xxx.datatypes.DataType), not marked as ignorable (1 known properties: "name"])
 at [Source: org.glassfish.jersey.message.internal.ReaderInterceptorExecutor$UnCloseableInputStream@526e34b1; line: 2, column: 15] (through reference chain: com.xxx.datatypes.DataType["name1"])

我更喜欢将上述错误转换为 JSON 响应。但事件我添加了以下异常映射器，它没有返回 JSON 响应。

@Provider …

minikube安装了什么：

$ ls -al /usr/local/bin/
-rwxr-xr-x  1 root root     26406912 Jun 14 12:05 docker-machine
-rwxrwxr-x  1 me libvirtd 11889064 Jun 14 12:07 docker-machine-driver-kvm
-rwxrwxr-x  1 me me     70232912 Jun 14 11:58 kubectl
-rwxrwxr-x  1 me me     82512696 Jun 14 11:57 minikube

尝试通过minikube启动集群

$ minikube start --vm-driver=kvm
Starting local Kubernetes v1.6.4 cluster...
Starting VM...
E0614 12:07:39.515994   14655 start.go:127] Error starting host: Error creating host: Error creating machine: Error in driver during machine creation: virError(Code=8, Domain=44, Message='invalid argument: could not find capabilities …

我读了一些代码：

class XXXX {
  init() {
    MyOBJ.on('EVENTNAME', this.myfunction.bind(this)); // Line3, MyOBJ extends EventEmitter
  }
}

只是好奇如何使用箭头函数替换 Line3？谢谢

我有一个内置到 jar 文件中的子项目。src/main/resources/db/migration/V1_1__create_table.sql项目里有。

如何从这个 jar 运行迁移？

我尝试了这个./flyway migrate -url=jdbc:postgresql://127.0.0.1:5432/myproject -user=myproject -password=myproject -locations=classpath:~/src/myproject/target/myproject-0.0.1-SNAPSHOT.jar，但出现以下错误：

Database: jdbc:postgresql://127.0.0.1:5432/myproject (PostgreSQL 9.6) WARNING: Unable to resolve location classpath:~/src/myproject/target/myprojectn-0/0/1-SNAPSHOT/jar WARNING: Schema "public" has version 0.0.6, but no migration could be resolved in the configured locations !

如何从 jar 运行迁移？谢谢。

我有一个由jenkins运行的python脚本。使用日志记录模块。

logging.basicConfig(filename="/tmp/test.log",
                    format="%(asctime)s %(levelname)s %(message)s",
                    filemode="a",
                    level=logging.INFO)

如果删除了上述配置，则无法找到以下语句生成的日志：

logging.info("xxxxxxx")

我没有在詹金斯机的系统日志中找到它。我在jenkins控制台输出中找不到它。

有什么提示吗？谢谢

我正在阅读https://angular.io/guide/forms。

我的代码：

  <!-- Min price -->
  <div class="form-group">
    <label for="minprice">Min price</label>
    <input type="number"
           min="0"
           class="form-control" id="minprice"
           required
           [(ngModel)]="model.minprice" name="minprice"
           #minprice="ngModel">
    <div [hidden]="minprice.valid"
         class="alert alert-danger">
      Min price is required
    </div>
  </div>

  <!-- Max price -->
  <div class="form-group">
    <label for="maxprice">Min price</label>
    <input type="number" class="form-control" id="maxprice"
           required
           min="0"
           [(ngModel)]="model.maxprice" name="maxprice"
           #maxprice="ngModel">
    <div [hidden]="maxprice.valid"
         class="alert alert-danger">
      Max price is required
    </div>
  </div>

我有两个问题：

1、min="0"好像不行。当我输入时-1，没有显示错误消息。

2、如何验证minprice小于maxprice？

欢迎任何提示。谢谢

我有很多很多FETCH_SESSION_ID_NOT_FOUND

INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=2] Node 1 was unable to process the fetch request with (sessionId=1229568311, epoch=511): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
INFO [ReplicaFetcher replicaId=2, leaderId=1, fetcherId=5] Node 1 was unable to process the fetch request with (sessionId=136816338, epoch=504): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
INFO [ReplicaFetcher replicaId=2, leaderId=0, fetcherId=2] Node 0 was unable to process the fetch request with (sessionId=311282207, epoch=569): FETCH_SESSION_ID_NOT_FOUND. (org.apache.kafka.clients.FetchSessionHandler)
...

我阅读了Kafka：连续获取 FETCH_SESSION_ID_NOT_FOUND和如何检查 Kafka 集群中使用的增量获取会话缓存槽的实际数量？

目前，我们刚刚从Burrow获得了有关滞后的指标。

我的问题：

1、谁能解释一下为什么我有这么多FETCH_SESSION_ID_NOT_FOUND？这是什么意思？我之前没有得到它们。

有些消费者发送了太多请求？还是领导人总是连任？

我不知道。有人可以给我更多细节吗？

2、如果是因为某些消费者发送的请求过多，如何识别这些消费者？

谢谢