遅延キュー-redis
文書ディレクトリ
前言
遅延キューの実装方法は多様であり,ここではredisのzsetで実現する.
一、予熱
zsetの考え方を使用すると、各valueにscore=期限切れのタイムスタンプを設定します.たとえば、現在のタイムスタンプが1609154995707で、60秒後に期限切れになったら、score=1609154995707+60を設定できます.その後、逆順序で並べ替え、期限切れのデータを取り出すたびに、ビジネス処理を行い、zsetから削除します.
redisコマンド:// key value , score
ZADD key score member
// member,value
ZREVRANGE key start stop [WITHSCORES]
// member1
ZREM key member [member ...]
二、java実現
1.ライブラリの導入
コードは次のとおりです(例).import numpy as np
import pandas as pd
import matplotlib.pyplot as plt
import seaborn as sns
import warnings
warnings.filterwarnings('ignore')
import ssl
ssl._create_default_https_context = ssl._create_unverified_context
2.データの読み込み
コードは次のとおりです(例).data = pd.read_csv(
'https://labfile.oss.aliyuncs.com/courses/1283/adult.data.csv')
print(data.head())
ここで使用するurlネットワークが要求するデータ.
三、欠点
まとめ
ヒント:ここでは文章をまとめます.例えば、以上は今日お話しする内容です.本文はpandasの使用を簡単に紹介しただけで、pandasはデータを迅速かつ容易に処理できる関数と方法を提供しています.
zsetの考え方を使用すると、各valueにscore=期限切れのタイムスタンプを設定します.たとえば、現在のタイムスタンプが1609154995707で、60秒後に期限切れになったら、score=1609154995707+60を設定できます.その後、逆順序で並べ替え、期限切れのデータを取り出すたびに、ビジネス処理を行い、zsetから削除します.
redisコマンド:
// key value , score
ZADD key score member
// member,value
ZREVRANGE key start stop [WITHSCORES]
// member1
ZREM key member [member ...]
二、java実現
1.ライブラリの導入
コードは次のとおりです(例).import numpy as np
import pandas as pd
import matplotlib.pyplot as plt
import seaborn as sns
import warnings
warnings.filterwarnings('ignore')
import ssl
ssl._create_default_https_context = ssl._create_unverified_context
2.データの読み込み
コードは次のとおりです(例).data = pd.read_csv(
'https://labfile.oss.aliyuncs.com/courses/1283/adult.data.csv')
print(data.head())
ここで使用するurlネットワークが要求するデータ.
三、欠点
まとめ
ヒント:ここでは文章をまとめます.例えば、以上は今日お話しする内容です.本文はpandasの使用を簡単に紹介しただけで、pandasはデータを迅速かつ容易に処理できる関数と方法を提供しています.
import numpy as np
import pandas as pd
import matplotlib.pyplot as plt
import seaborn as sns
import warnings
warnings.filterwarnings('ignore')
import ssl
ssl._create_default_https_context = ssl._create_unverified_context
data = pd.read_csv(
'https://labfile.oss.aliyuncs.com/courses/1283/adult.data.csv')
print(data.head())