من در چند روز گذشته در حال یادگیری و پیاده‌سازی جریان‌های Redis برای راه‌اندازی یک سیستم ارتباطی بی‌درنگ و مدیریت صف برای LiveAPI محصولمان، یک ابزار خودکار تولید سند API، هستم.
در این مقاله، اجازه دهید در مورد چند دستور Redis Stream صحبت کنیم که باید هنگام ساخت راه حل های کارآمد با استفاده از Redis Stream از آنها آگاه باشید.
- XADD: این دستور به اضافه کردن ورودی های جدید به یک جریان کمک می کند. مثال:
XADD mystream * sensor-id 1234 temperature 19.8 humidity 43.5
این دستور یک ورودی جدید به جریان “mystream” اضافه می کند. * به Redis می گوید که شناسه ورودی را به طور خودکار تولید کند. هر ورودی حاوی چندین جفت مقدار میدان (شناسه حسگر، دما، رطوبت) است.
2.XREAD: این دستور ورودی های یک یا چند جریان را می خواند.
مثال: XREAD COUNT 2 STREAMS mystream 0
این 2 ورودی را از “mystream” از ابتدا می خواند (ID 0).
3.XRANGE: این دستور ورودی های یک محدوده ID خاص را برمی گرداند.
مثال: XRANGE mystream 1641293000000-0 1641293060000-0
این دستور برای دریافت داده های تاریخی در یک محدوده خاص استفاده می شود.
4.XGROUP CREATE: یک گروه مصرف کننده برای پردازش جریان ایجاد می کند.
مثال: XGROUP CREATE mystream mygroup $
یک گروه مصرف کننده به نام “mygroup” برای “mystream” ایجاد می کند. $ به این معنی است که گروه فقط پیام های جدید (از آخرین شناسه) را می خواند.
5.XREADGROUP: از یک جریان به عنوان بخشی از یک گروه مصرف کننده می خواند.
مثال: XREADGROUP GROUP mygroup consumer1 COUNT 1 STREAMS mystream >
این یک پیام خوانده نشده از «mystream» به عنوان customers1 در mygroup می خواند. > به معنای “پیام های جدیدی به من بدهید که به دیگر مصرف کنندگان تحویل داده نشده اند”.
6.XCLAIM: برای انتقال مالکیت پیام های معلق استفاده می شود.
مثال: XCLAIM mystream mygroup consumer2 30000 1692312456878-0
این دستور مالکیت را از یک مصرف کننده به مصرف کننده دیگر در همان گروه مصرف کننده منتقل می کند. این به ویژه در مدیریت مصرف کنندگان شکست خورده یا متعادل کردن بار کاری مفید است. XCLAIM تضمین می کند که در صورت شکست مصرف کننده هیچ پیامی از بین نمی رود، توزیع مجدد کار را برای متعادل کردن بار بهتر فعال می کند و مکانیسم های بازیابی پیام را فراهم می کند.
امیدوارم این چند دستور به شما کمک کند تا در مورد جریان های Redis و دستورات آنها ایده بگیرید. نظرات ارزشمند خود را به اشتراک بگذارید
