问题标签 [stream-framework]

2017 年 6 月 8 日更新

虽然 3 年过去了，但我的PR仍然作为临时解决方案通过执行输出命令来解决。Stream-Framework 可能会重新考虑使用内容作为通知键的设计。GitHub问题 #153引用了这个。

问题

请参阅以下示例：

结果：

显然，每次转储的序列化输出都会发生变化。当我从任何键中删除一个字符时，这不会发生。我发现这是因为Stream-Framework使用腌制输出作为在其 k/v 存储上存储通知的关键。如果我们更好地了解这里发生的事情，我会提出请求。我找到了两种解决方案来防止它：

A - 排序后转换为字典（是的，以某种方式提供预期的副作用）

B - 删除下划线（但不确定这是否总是有效）

那么是什么导致了pickle字典排序下的谜团呢？

证明在 dict 上调用 sort 会提供转储以产生相同的结果：

我们正在构建基于 django 的 REST API，其中一项功能是新闻提要。经过一番谷歌搜索后，我可以看到以下 2 个选项：

• Django Activity Stream（必须在此之上使用 Redis）

• 流框架（以前称为 Feedly）

我的问题是，考虑到开发时间和可扩展性，哪一个更合适？

对于使用 python 流框架包的任何人，我想知道您对使用 Cassandra 的想法。我目前正在尝试构建一个基于 Cassandra 的通知提要，它支持未读计数，并将整个提要标记为已读。IT 似乎基本流框架仅支持 Redis 的 NotificationFeed。

1) 对于框架的作者，这可以使用 Cassandra 完成吗？

2）对于其他任何人，这是我正在处理的通知提要的精简模型：

提要中的每个活动都有一个已读和已查看标志。对于任何单个活动，通过其主键（特定的提要和给定的活动 ID）很容易找到它，从而更新列。但是，在 cassandra 2.2+ 中，无法将整个提要的活动价值更新为已读（因为您必须提供完整的主键并且不能使用二级索引）。（注意：在 cassandra 3.0 中，您似乎可以将 IN 运算符用于集群键，因此您可以分两步执行此操作：使用二级索引查找 activity_id where read=False，然后通过单个查询使用结果IN 更新它们）。

我希望这是有道理的，如果没有，我会提供任何需要的澄清。

首先是我想要实现的一点。我在流框架库之上构建了一个 django 包装器。有 2 个提要类 -FlatFeed(RedisFeed)和AggregatedFeed(RedisAggregatedFeed). 显然，这些都是使用 Redis 来存储提要数据。我还实现了我自己的聚合器类。

错误：生成的聚合提要不包含所有活动，而平面提要包含所有活动。用例是 - 有 3 个用户 A、B 和 C。B 和 C 执行一些活动，然后用户 A 跟随 B 和 C。用户 B 和 C 继续执行更多活动。A 的平面提要包含 B 和 C 的所有活动，但 A 的聚合提要有一些丢失的活动。

例如，

flat_feed(A) 有所有活动，但aggregated_feed(A)只有 1、5 和 8 个喜欢。我多次重复这个用例，每次只有这 3 个活动来。

我已经在 django shell 上测试了我的聚合器类实现。聚合和合并函数的输出包含所有活动。

请帮忙 ！！

请注意，固定提要有正确的条目，缺少的条目仅在汇总提要中。

我的 Linux 机器上有 Cassandra 3.x。我尝试使用https://github.com/tschellenbach/Stream-Framework连接到它

我可以从命令行连接到 Cassandracqlsh' and using我可以从端口 9042 上的命令行 DBeaver GUI

当我尝试使用上述导入运行 Django 时，出现此错误：

编辑 3 当所有设置都为默认值时，我也得到

我四处寻找解决方案并更改 /etc/cassandra/cassandra.yaml为：

但它没有帮助。

关于如何解决它的任何想法？

编辑 我把事情变成了默认设置和netstat -nat | grep 9042

顺便说一句，nodetool status退货

编辑 2
我不确定这是否是某种线索，但是当我使用 DBeaver 连接到 Cassandra 时，我只列出了一个主机：

是 IPv6 而不是 IPv4？

如何调整流框架以使其使​​用 postgreSQL 而不是 Redis

我正在尝试设置基本提要：

但是当我feed[:2]在添加一个活动后运行时，我不断收到这个错误：

我可以打印出来[<stream_framework.activity.DehydratedActivity object at 0x10e114e90>]并且[u'14929294667170000000001005'].

任何线索可能导致这种情况？

我正在尝试在我的应用程序（不是 Django）中使用 stream_framework，但在调用 stream_framework 共享任务时遇到问题。Celery 似乎找到了任务：

我用以下方式运行芹菜：

我的 celery_app 有：

问题是 delay() 不运行共享任务。我还在我的应用程序中创建了一个共享任务，但是当我调用 delay() 时，也不会调用该任务。我想我需要将它们注册为可从我的应用程序调用？我似乎在网上找不到任何信息。

我也尝试自动发现任务，但我遇到了同样的问题：

任何想法都受到高度赞赏。

我正在尝试使用 docker-compose up 构建一个 docker 文件，但出现错误：

这是我的 docker 文件和 docker-compose-yml 文件： dockerfile:

码头工人撰写：

我遵循了流框架conf，但仍然出现错误，例如int没有项目，pinmanager不是json序列化的任何人都可以说redis的版本，celery和conf设置，以便我可以设置